Class MesosExecutorDriver

src/java/src/org/apache/mesos/MesosExecutorDriver.java:50–98

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

 * </p>
 */
public class MesosExecutorDriver implements ExecutorDriver {
  static {
    MesosNativeLibrary.load();
  }

  /**
   * Creates a new driver that uses the specified Executor.
   *
   * @param executor    The instance of the executor that will be used
   *                    to connect to the slave.
   *
   * @see Executor
   */
  public MesosExecutorDriver(Executor executor) {
    if (executor == null) {
      throw new NullPointerException("Not expecting a null Executor");
    }

    this.executor = executor;

    initialize();
  }

  /**
   * See ExecutorDriver for descriptions of these.
   *
   * @see ExecutorDriver
   */
  public native Status start();
  public native Status stop();
  public native Status abort();
  public native Status join();

  public Status run() {
    Status status = start();
    return status != Status.DRIVER_RUNNING ? status : join();
  }

  public native Status sendStatusUpdate(TaskStatus status);
  public native Status sendFrameworkMessage(byte[] data);

  protected native void initialize();
  protected native void finalize();

  private final Executor executor;

  private long __executor;
  private long __driver;
}