org.apache.mesos

Class MesosExecutorDriver

java.lang.Object

org.apache.mesos.MesosExecutorDriver

All Implemented Interfaces:

ExecutorDriver

public class MesosExecutorDriver
extends java.lang.Object
implements ExecutorDriver

Concrete implementation of an ExecutorDriver that connects an Executor with a Mesos slave. The MesosExecutorDriver is thread-safe.

The driver is responsible for invoking the Executor callbacks as it communicates with the Mesos slave.

Note that blocking on the MesosExecutorDriver (e.g., via join()) doesn't affect the executor callbacks in anyway because they are handled by a different thread.

Note that the driver uses GLOG to do its own logging. GLOG flags can be set via environment variables, prefixing the flag name with "GLOG_", e.g., "GLOG_v=1". For Mesos specific logging flags see src/logging/flags.hpp. Mesos flags can also be set via environment variables, prefixing the flag name with "MESOS_", e.g., "MESOS_QUIET=1".

See src/examples/java/TestExecutor.java for an example of using the MesosExecutorDriver.

Constructor Summary

Constructors

Constructor and Description
MesosExecutorDriver(Executor executor) Creates a new driver that uses the specified Executor.

Method Summary

Modifier and Type	Method and Description
Protos.Status	abort() Aborts the driver so that no more callbacks can be made to the executor.
protected void	finalize()
protected void	initialize()
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() See ExecutorDriver for descriptions of these.
Protos.Status	stop() Stops the executor driver.

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MesosExecutorDriver

public MesosExecutorDriver(Executor executor)

Creates a new driver that uses the specified Executor.

Parameters:

executor - The instance of the executor that will be used to connect to the slave.

See Also:

Executor

Method Detail

start

public Protos.Status start()

See ExecutorDriver for descriptions of these.

Specified by:

start in interface ExecutorDriver

Returns:

The state of the driver after the call.

See Also:

ExecutorDriver

stop

public Protos.Status stop()

Description copied from interface: ExecutorDriver

Stops the executor driver.

Specified by:

stop in interface ExecutorDriver

Returns:

The state of the driver after the call.

See Also:

Protos.Status

abort

public Protos.Status abort()

Description copied from interface: ExecutorDriver

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 ExecutorDriver.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).

Specified by:

abort in interface ExecutorDriver

Returns:

The state of the driver after the call.

See Also:

Protos.Status

join

public Protos.Status join()

Description copied from interface: ExecutorDriver

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).

Specified by:

join in interface ExecutorDriver

Returns:

The state of the driver after the call.

See Also:

Protos.Status

run

public Protos.Status run()

Description copied from interface: ExecutorDriver

Starts and immediately joins (i.e., blocks on) the driver.

Specified by:

run in interface ExecutorDriver

Returns:

The state of the driver after the call.

See Also:

Protos.Status

sendStatusUpdate

public Protos.Status sendStatusUpdate(Protos.TaskStatus status)

Description copied from interface: ExecutorDriver

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.

Specified by:

sendStatusUpdate in interface ExecutorDriver

Parameters:

status - The status update to send.

Returns:

The state of the driver after the call.

See Also:

Protos.Status

sendFrameworkMessage

public Protos.Status sendFrameworkMessage(byte[] data)

Description copied from interface: ExecutorDriver

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.

Specified by:

sendFrameworkMessage in interface ExecutorDriver

Parameters:

data - The message payload.

Returns:

The state of the driver after the call.

See Also:

Protos.Status

initialize

protected void initialize()

finalize

protected void finalize()

Overrides:

finalize in class java.lang.Object