org.apache.flink.mesos.scheduler

Class SchedulerProxy

java.lang.Object

org.apache.flink.mesos.scheduler.SchedulerProxy

All Implemented Interfaces:

org.apache.mesos.Scheduler

public class SchedulerProxy
extends Object
implements org.apache.mesos.Scheduler

This class reacts to callbacks from the Mesos scheduler driver.

In order to preserve actor concurrency safety, this class simply sends corresponding messages to the Mesos resource master actor.

See https://mesos.apache.org/api/latest/java/org/apache/mesos/Scheduler.html

Constructor Summary

Constructors

Constructor and Description
SchedulerProxy(akka.actor.ActorRef mesosActor)

Method Summary

Modifier and Type	Method and Description
void	disconnected(org.apache.mesos.SchedulerDriver driver)
void	error(org.apache.mesos.SchedulerDriver driver, String message)
void	executorLost(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.ExecutorID executorId, org.apache.mesos.Protos.SlaveID slaveId, int status)
void	frameworkMessage(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.ExecutorID executorId, org.apache.mesos.Protos.SlaveID slaveId, byte[] data)
void	offerRescinded(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.OfferID offerId)
void	registered(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.FrameworkID frameworkId, org.apache.mesos.Protos.MasterInfo masterInfo)
void	reregistered(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.MasterInfo masterInfo)
void	resourceOffers(org.apache.mesos.SchedulerDriver driver, List<org.apache.mesos.Protos.Offer> offers)
void	slaveLost(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.SlaveID slaveId)
void	statusUpdate(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.TaskStatus status)

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulerProxy

public SchedulerProxy(akka.actor.ActorRef mesosActor)

Method Detail

registered

public void registered(org.apache.mesos.SchedulerDriver driver,
                       org.apache.mesos.Protos.FrameworkID frameworkId,
                       org.apache.mesos.Protos.MasterInfo masterInfo)

Specified by:

registered in interface org.apache.mesos.Scheduler

reregistered

public void reregistered(org.apache.mesos.SchedulerDriver driver,
                         org.apache.mesos.Protos.MasterInfo masterInfo)

Specified by:

reregistered in interface org.apache.mesos.Scheduler

disconnected

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

Specified by:

disconnected in interface org.apache.mesos.Scheduler

resourceOffers

public void resourceOffers(org.apache.mesos.SchedulerDriver driver,
                           List<org.apache.mesos.Protos.Offer> offers)

Specified by:

resourceOffers in interface org.apache.mesos.Scheduler

offerRescinded

public void offerRescinded(org.apache.mesos.SchedulerDriver driver,
                           org.apache.mesos.Protos.OfferID offerId)

Specified by:

offerRescinded in interface org.apache.mesos.Scheduler

statusUpdate

public void statusUpdate(org.apache.mesos.SchedulerDriver driver,
                         org.apache.mesos.Protos.TaskStatus status)

Specified by:

statusUpdate in interface org.apache.mesos.Scheduler

frameworkMessage

public void frameworkMessage(org.apache.mesos.SchedulerDriver driver,
                             org.apache.mesos.Protos.ExecutorID executorId,
                             org.apache.mesos.Protos.SlaveID slaveId,
                             byte[] data)

Specified by:

frameworkMessage in interface org.apache.mesos.Scheduler

slaveLost

public void slaveLost(org.apache.mesos.SchedulerDriver driver,
                      org.apache.mesos.Protos.SlaveID slaveId)

Specified by:

slaveLost in interface org.apache.mesos.Scheduler

executorLost

public void executorLost(org.apache.mesos.SchedulerDriver driver,
                         org.apache.mesos.Protos.ExecutorID executorId,
                         org.apache.mesos.Protos.SlaveID slaveId,
                         int status)

Specified by:

executorLost in interface org.apache.mesos.Scheduler

error

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

Specified by:

error in interface org.apache.mesos.Scheduler