org.apache.flink.mesos.scheduler

Interface LaunchableTask

All Known Implementing Classes:

LaunchableMesosWorker

public interface LaunchableTask

Specifies the task requirements and produces a Mesos TaskInfo description.

Method Summary

Modifier and Type	Method and Description
org.apache.mesos.Protos.TaskInfo	launch(org.apache.mesos.Protos.SlaveID slaveId, MesosResourceAllocation allocation) Prepare to launch the task by producing a Mesos TaskInfo record.
com.netflix.fenzo.TaskRequest	taskRequest() Get a representation of the task requirements as understood by Fenzo.

Method Detail

taskRequest

com.netflix.fenzo.TaskRequest taskRequest()

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

launch

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

Prepare to launch the task by producing a Mesos TaskInfo record.

Parameters:

slaveId - the slave assigned to the task.

allocation - the resource allocation to take from.

Returns:

a TaskInfo.