public class IgniteScheduler extends Object implements org.apache.mesos.Scheduler
| Modifier and Type | Field and Description |
|---|---|
static String |
CPU
Cpus.
|
static String |
DEFAULT_PORT
Default port range.
|
static String |
DELIM
Delimiter char.
|
static String |
DISK
Disk.
|
static String |
MEM
Mem.
|
| Constructor and Description |
|---|
IgniteScheduler(ClusterProperties clusterProps,
ResourceProvider resourceProvider) |
| Modifier and Type | Method and Description |
|---|---|
void |
disconnected(org.apache.mesos.SchedulerDriver schedulerDriver) |
void |
error(org.apache.mesos.SchedulerDriver schedulerDriver,
String s) |
void |
executorLost(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.ExecutorID executorID,
org.apache.mesos.Protos.SlaveID slaveID,
int i) |
void |
frameworkMessage(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.ExecutorID executorID,
org.apache.mesos.Protos.SlaveID slaveID,
byte[] bytes) |
void |
offerRescinded(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.OfferID offerID) |
void |
registered(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.FrameworkID frameworkID,
org.apache.mesos.Protos.MasterInfo masterInfo) |
void |
reregistered(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.MasterInfo masterInfo) |
void |
resourceOffers(org.apache.mesos.SchedulerDriver schedulerDriver,
List<org.apache.mesos.Protos.Offer> offers) |
void |
setClusterProps(ClusterProperties clusterProps) |
void |
slaveLost(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.SlaveID slaveID) |
void |
statusUpdate(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.TaskStatus taskStatus) |
public static final String CPU
public static final String MEM
public static final String DISK
public static final String DEFAULT_PORT
public static final String DELIM
public IgniteScheduler(ClusterProperties clusterProps, ResourceProvider resourceProvider)
clusterProps - Cluster limit.resourceProvider - Resource provider.public void resourceOffers(org.apache.mesos.SchedulerDriver schedulerDriver,
List<org.apache.mesos.Protos.Offer> offers)
resourceOffers in interface org.apache.mesos.Schedulerpublic void statusUpdate(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.TaskStatus taskStatus)
statusUpdate in interface org.apache.mesos.Schedulerpublic void setClusterProps(ClusterProperties clusterProps)
clusterProps - Cluster properties.public void registered(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.FrameworkID frameworkID,
org.apache.mesos.Protos.MasterInfo masterInfo)
registered in interface org.apache.mesos.Schedulerpublic void disconnected(org.apache.mesos.SchedulerDriver schedulerDriver)
disconnected in interface org.apache.mesos.Schedulerpublic void error(org.apache.mesos.SchedulerDriver schedulerDriver,
String s)
error in interface org.apache.mesos.Schedulerpublic void frameworkMessage(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.ExecutorID executorID,
org.apache.mesos.Protos.SlaveID slaveID,
byte[] bytes)
frameworkMessage in interface org.apache.mesos.Schedulerpublic void slaveLost(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.SlaveID slaveID)
slaveLost in interface org.apache.mesos.Schedulerpublic void executorLost(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.ExecutorID executorID,
org.apache.mesos.Protos.SlaveID slaveID,
int i)
executorLost in interface org.apache.mesos.Schedulerpublic void offerRescinded(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.OfferID offerID)
offerRescinded in interface org.apache.mesos.Schedulerpublic void reregistered(org.apache.mesos.SchedulerDriver schedulerDriver,
org.apache.mesos.Protos.MasterInfo masterInfo)
reregistered in interface org.apache.mesos.Scheduler
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016