org.apache.flink.mesos.runtime.clusterframework

Interface MesosResourceManagerActions

public interface MesosResourceManagerActions

Actions defined by the MesosResourceManager.

These are called by the MesosResourceManager components such as LaunchCoordinator, and TaskMonitor.

Method Summary

Modifier and Type	Method and Description
void	acceptOffers(AcceptOffers offersToAccept) Accept the given offers as advised by the launch coordinator.
void	reconcile(org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile reconciliationRequest) Trigger reconciliation with the Mesos master.
void	taskTerminated(org.apache.flink.mesos.scheduler.TaskMonitor.TaskTerminated terminatedTask) Notify that the given Mesos task has been terminated.

Method Detail

acceptOffers

void acceptOffers(AcceptOffers offersToAccept)

Accept the given offers as advised by the launch coordinator.

Note: This method is a callback for the LaunchCoordinator.

Parameters:

offersToAccept - Offers to accept from Mesos

reconcile

void reconcile(org.apache.flink.mesos.scheduler.ReconciliationCoordinator.Reconcile reconciliationRequest)

Trigger reconciliation with the Mesos master.

Note: This method is a callback for the TaskMonitor.

Parameters:

reconciliationRequest - Message containing the tasks which shall be reconciled

taskTerminated

void taskTerminated(org.apache.flink.mesos.scheduler.TaskMonitor.TaskTerminated terminatedTask)

Notify that the given Mesos task has been terminated.

Note: This method is a callback for the TaskMonitor.

Parameters:

terminatedTask - Message containing the terminated task