org.apache.reef.runtime.mesos.evaluator

Class REEFExecutor

java.lang.Object

org.apache.reef.runtime.mesos.evaluator.REEFExecutor

All Implemented Interfaces:

org.apache.mesos.Executor

public final class REEFExecutor
extends Object
implements org.apache.mesos.Executor

REEF implementation of Mesos Executor.

Method Summary

Methods

Modifier and Type	Method and Description
void	disconnected(org.apache.mesos.ExecutorDriver driver)
void	error(org.apache.mesos.ExecutorDriver driver, String message)
void	frameworkMessage(org.apache.mesos.ExecutorDriver driver, byte[] data)
void	killTask(org.apache.mesos.ExecutorDriver driver, org.apache.mesos.Protos.TaskID taskId)
void	launchTask(org.apache.mesos.ExecutorDriver driver, org.apache.mesos.Protos.TaskInfo task) We assume a long-running Mesos Task that manages a REEF Evaluator process, leveraging Mesos Executor's interface.
static void	main(String[] args) The starting point of the executor.
void	onEvaluatorLaunch(EvaluatorLaunch evaluatorLaunch)
void	onEvaluatorRelease(EvaluatorRelease evaluatorRelease)
static Configuration	parseCommandLine(String[] args)
void	registered(org.apache.mesos.ExecutorDriver driver, org.apache.mesos.Protos.ExecutorInfo executorInfo, org.apache.mesos.Protos.FrameworkInfo frameworkInfo, org.apache.mesos.Protos.SlaveInfo slaveInfo)
void	reregistered(org.apache.mesos.ExecutorDriver driver, org.apache.mesos.Protos.SlaveInfo slaveInfo)
void	shutdown(org.apache.mesos.ExecutorDriver driver)

Methods inherited from class java.lang.Object

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

Method Detail

registered

public void registered(org.apache.mesos.ExecutorDriver driver,
              org.apache.mesos.Protos.ExecutorInfo executorInfo,
              org.apache.mesos.Protos.FrameworkInfo frameworkInfo,
              org.apache.mesos.Protos.SlaveInfo slaveInfo)

Specified by:

registered in interface org.apache.mesos.Executor

reregistered

public void reregistered(org.apache.mesos.ExecutorDriver driver,
                org.apache.mesos.Protos.SlaveInfo slaveInfo)

Specified by:

reregistered in interface org.apache.mesos.Executor

disconnected

public void disconnected(org.apache.mesos.ExecutorDriver driver)

Specified by:

disconnected in interface org.apache.mesos.Executor

launchTask

public void launchTask(org.apache.mesos.ExecutorDriver driver,
              org.apache.mesos.Protos.TaskInfo task)

We assume a long-running Mesos Task that manages a REEF Evaluator process, leveraging Mesos Executor's interface.

Specified by:

launchTask in interface org.apache.mesos.Executor

killTask

public void killTask(org.apache.mesos.ExecutorDriver driver,
            org.apache.mesos.Protos.TaskID taskId)

Specified by:

killTask in interface org.apache.mesos.Executor

frameworkMessage

public void frameworkMessage(org.apache.mesos.ExecutorDriver driver,
                    byte[] data)

Specified by:

frameworkMessage in interface org.apache.mesos.Executor

shutdown

public void shutdown(org.apache.mesos.ExecutorDriver driver)

Specified by:

shutdown in interface org.apache.mesos.Executor

error

public void error(org.apache.mesos.ExecutorDriver driver,
         String message)

Specified by:

error in interface org.apache.mesos.Executor

onEvaluatorRelease

public void onEvaluatorRelease(EvaluatorRelease evaluatorRelease)

onEvaluatorLaunch

public void onEvaluatorLaunch(EvaluatorLaunch evaluatorLaunch)

parseCommandLine

public static Configuration parseCommandLine(String[] args)
                                      throws IOException

Throws:

IOException

main

public static void main(String[] args)
                 throws Exception

The starting point of the executor.

Throws:

Exception