public final class REEFExecutor extends Object implements org.apache.mesos.Executor
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) |
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)
registered
in interface org.apache.mesos.Executor
public void reregistered(org.apache.mesos.ExecutorDriver driver, org.apache.mesos.Protos.SlaveInfo slaveInfo)
reregistered
in interface org.apache.mesos.Executor
public void disconnected(org.apache.mesos.ExecutorDriver driver)
disconnected
in interface org.apache.mesos.Executor
public void launchTask(org.apache.mesos.ExecutorDriver driver, org.apache.mesos.Protos.TaskInfo task)
launchTask
in interface org.apache.mesos.Executor
public void killTask(org.apache.mesos.ExecutorDriver driver, org.apache.mesos.Protos.TaskID taskId)
killTask
in interface org.apache.mesos.Executor
public void frameworkMessage(org.apache.mesos.ExecutorDriver driver, byte[] data)
frameworkMessage
in interface org.apache.mesos.Executor
public void shutdown(org.apache.mesos.ExecutorDriver driver)
shutdown
in interface org.apache.mesos.Executor
public void error(org.apache.mesos.ExecutorDriver driver, String message)
error
in interface org.apache.mesos.Executor
public void onEvaluatorRelease(EvaluatorRelease evaluatorRelease)
public void onEvaluatorLaunch(EvaluatorLaunch evaluatorLaunch)
public static Configuration parseCommandLine(String[] args) throws IOException
IOException
Copyright © 2017 The Apache Software Foundation. All rights reserved.