ExecutorDriver

All Known Implementing Classes:

MesosExecutorDriver
```
public interface ExecutorDriver
```
Abstract interface for connecting an executor to Mesos. This interface is used both to manage the executor's lifecycle (start it, stop it, or wait for it to finish) and to interact with Mesos (e.g., send status updates, send framework messages, etc.).

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`Protos.Status`	`abort()` Aborts the driver so that no more callbacks can be made to the executor.
`Protos.Status`	`join()` Waits for the driver to be stopped or aborted, possibly _blocking_ the current thread indefinitely.
`Protos.Status`	`run()` Starts and immediately joins (i.e., blocks on) the driver.
`Protos.Status`	`sendFrameworkMessage(byte[] data)` Sends a message to the framework scheduler.
`Protos.Status`	`sendStatusUpdate(Protos.TaskStatus status)` Sends a status update to the framework scheduler, retrying as necessary until an acknowledgement has been received or the executor is terminated (in which case, a TASK_LOST status update will be sent).
`Protos.Status`	`start()` Starts the executor driver.
`Protos.Status`	`stop()` Stops the executor driver.

- Method Detail
  - start
```
Protos.Status start()
```
    Starts the executor driver. This needs to be called before any other driver calls are made.
    
    Returns:
    
    The state of the driver after the call.
    
    See Also:
    
    Protos.Status
  - stop
```
Protos.Status stop()
```
    Stops the executor driver.
    
    Returns:
    
    The state of the driver after the call.
    
    See Also:
    
    Protos.Status
  - abort
```
Protos.Status abort()
```
    Aborts the driver so that no more callbacks can be made to the executor. The semantics of abort and stop have deliberately been separated so that code can detect an aborted driver (i.e., via the return status of join(), see below), and instantiate and start another driver if desired (from within the same process ... although this functionality is currently not supported for executors).
    
    Returns:
    
    The state of the driver after the call.
    
    See Also:
    
    Protos.Status
  - join
```
Protos.Status join()
```
    Waits for the driver to be stopped or aborted, possibly _blocking_ the current thread indefinitely. The return status of this function can be used to determine if the driver was aborted (see mesos.proto for a description of Status).
    
    Returns:
    
    The state of the driver after the call.
    
    See Also:
    
    Protos.Status
  - run
```
Protos.Status run()
```
    Starts and immediately joins (i.e., blocks on) the driver.
    
    Returns:
    
    The state of the driver after the call.
    
    See Also:
    
    Protos.Status
  - sendStatusUpdate
```
Protos.Status sendStatusUpdate(Protos.TaskStatus status)
```
    Sends a status update to the framework scheduler, retrying as necessary until an acknowledgement has been received or the executor is terminated (in which case, a TASK_LOST status update will be sent). See Scheduler.statusUpdate(org.apache.mesos.SchedulerDriver, org.apache.mesos.Protos.TaskStatus) for more information about status update acknowledgements.
    
    Parameters:
    
    status - The status update to send.
    
    Returns:
    
    The state of the driver after the call.
    
    See Also:
    
    Protos.Status
  - sendFrameworkMessage
```
Protos.Status sendFrameworkMessage(byte[] data)
```
    Sends a message to the framework scheduler. These messages are best effort; do not expect a framework message to be retransmitted in any reliable fashion.
    
    Parameters:
    
    data - The message payload.
    
    Returns:
    
    The state of the driver after the call.
    
    See Also:
    
    Protos.Status

Interface ExecutorDriver

Method Summary

Method Detail

start

stop

abort

join

run

sendStatusUpdate

sendFrameworkMessage