org.apache.flink.mesos.runtime.clusterframework

Class LaunchableMesosWorker

java.lang.Object

org.apache.flink.mesos.runtime.clusterframework.LaunchableMesosWorker

All Implemented Interfaces:

LaunchableTask

public class LaunchableMesosWorker
extends Object
implements LaunchableTask

Implements the launch of a Mesos worker.

Translates the abstract ContainerSpecification into a concrete Mesos-specific Protos.TaskInfo.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
LaunchableMesosWorker(MesosArtifactResolver resolver, MesosTaskManagerParameters params, org.apache.flink.runtime.clusterframework.ContainerSpecification containerSpec, org.apache.mesos.Protos.TaskID taskID, MesosConfiguration mesosConfiguration) Construct a launchable Mesos worker.

Method Summary

Modifier and Type	Method and Description
org.apache.mesos.Protos.TaskInfo	launch(org.apache.mesos.Protos.SlaveID slaveId, MesosResourceAllocation allocation) Construct the TaskInfo needed to launch the worker.
org.apache.mesos.Protos.TaskID	taskID()
com.netflix.fenzo.TaskRequest	taskRequest() Get a representation of the task requirements as understood by Fenzo.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

LaunchableMesosWorker

public LaunchableMesosWorker(MesosArtifactResolver resolver,
                             MesosTaskManagerParameters params,
                             org.apache.flink.runtime.clusterframework.ContainerSpecification containerSpec,
                             org.apache.mesos.Protos.TaskID taskID,
                             MesosConfiguration mesosConfiguration)

Construct a launchable Mesos worker.

Parameters:

resolver - The resolver for retrieving artifacts (e.g. jars, configuration)

params - the TM parameters such as memory, cpu to acquire.

containerSpec - an abstract container specification for launch time.

taskID - the taskID for this worker.

Method Detail

taskID

public org.apache.mesos.Protos.TaskID taskID()

taskRequest

public com.netflix.fenzo.TaskRequest taskRequest()

Description copied from interface: LaunchableTask

Get a representation of the task requirements as understood by Fenzo.

Specified by:

taskRequest in interface LaunchableTask

launch

public org.apache.mesos.Protos.TaskInfo launch(org.apache.mesos.Protos.SlaveID slaveId,
                                               MesosResourceAllocation allocation)

Construct the TaskInfo needed to launch the worker.

Specified by:

launch in interface LaunchableTask

Parameters:

slaveId - the assigned slave.

allocation - the resource allocation (available resources).

Returns:

a fully-baked TaskInfo.

toString

public String toString()

Overrides:

toString in class Object