| Package | Description |
|---|---|
| edu.snu.coral.runtime.master | |
| edu.snu.coral.runtime.master.scheduler |
| Constructor and Description |
|---|
RuntimeMaster(Scheduler scheduler,
SchedulerRunner schedulerRunner,
PendingTaskGroupQueue pendingTaskGroupQueue,
ContainerManager containerManager,
BlockManagerMaster blockManagerMaster,
MetricMessageHandler metricMessageHandler,
MessageEnvironment masterMessageEnvironment,
String dagDirectory) |
| Modifier and Type | Class and Description |
|---|---|
class |
SingleJobTaskGroupQueue
Keep tracks of all pending task groups.
|
| Constructor and Description |
|---|
BatchSingleJobScheduler(SchedulingPolicy schedulingPolicy,
SchedulerRunner schedulerRunner,
PendingTaskGroupQueue pendingTaskGroupQueue,
BlockManagerMaster blockManagerMaster,
PubSubEventHandlerWrapper pubSubEventHandlerWrapper,
UpdatePhysicalPlanEventHandler updatePhysicalPlanEventHandler) |
SchedulerRunner(SchedulingPolicy schedulingPolicy,
PendingTaskGroupQueue pendingTaskGroupQueue) |
Copyright © 2018. All rights reserved.