Uses of Class
edu.snu.coral.runtime.common.plan.physical.ScheduledTaskGroup

Packages that use ScheduledTaskGroup

Package	Description
edu.snu.coral.runtime.executor
edu.snu.coral.runtime.master.resource
edu.snu.coral.runtime.master.scheduler

Uses of ScheduledTaskGroup in edu.snu.coral.runtime.executor

Constructors in edu.snu.coral.runtime.executor with parameters of type ScheduledTaskGroup

Constructor and Description
TaskGroupExecutor(ScheduledTaskGroup scheduledTaskGroup, DAG<Task,RuntimeEdge<Task>> taskGroupDag, TaskGroupStateManager taskGroupStateManager, DataTransferFactory channelFactory)
TaskGroupStateManager(ScheduledTaskGroup scheduledTaskGroup, DAG<Task,RuntimeEdge<Task>> taskGroupDag, String executorId, PersistentConnectionToMasterMap persistentConnectionToMasterMap, MetricMessageSender metricMessageSender)

Uses of ScheduledTaskGroup in edu.snu.coral.runtime.master.resource

Methods in edu.snu.coral.runtime.master.resource with parameters of type ScheduledTaskGroup

Modifier and Type	Method and Description
void	ExecutorRepresenter.onTaskGroupScheduled(ScheduledTaskGroup scheduledTaskGroup)

Uses of ScheduledTaskGroup in edu.snu.coral.runtime.master.scheduler

Methods in edu.snu.coral.runtime.master.scheduler that return types with arguments of type ScheduledTaskGroup

Modifier and Type	Method and Description
Optional<ScheduledTaskGroup>	SingleJobTaskGroupQueue.dequeue() Dequeues the next TaskGroup to be scheduled according to job dependency priority.
Optional<ScheduledTaskGroup>	PendingTaskGroupQueue.dequeue() Dequeues the next TaskGroup to be scheduled.

Methods in edu.snu.coral.runtime.master.scheduler with parameters of type ScheduledTaskGroup

Modifier and Type	Method and Description
void	SingleJobTaskGroupQueue.enqueue(ScheduledTaskGroup scheduledTaskGroup)
void	PendingTaskGroupQueue.enqueue(ScheduledTaskGroup scheduledTaskGroup) Enqueues a TaskGroup to this PQ.
boolean	RoundRobinSchedulingPolicy.scheduleTaskGroup(ScheduledTaskGroup scheduledTaskGroup, JobStateManager jobStateManager)
boolean	SchedulingPolicy.scheduleTaskGroup(ScheduledTaskGroup scheduledTaskGroup, JobStateManager jobStateManager) Attempts to schedule the given taskGroup to an executor according to this policy.