Package org.apache.nemo.runtime.master.scheduler

Interface Summary

Interface	Description
Scheduler	Only two threads call scheduling code: RuntimeMaster thread (RMT), and SchedulerThread(ST).
SchedulingConstraint	Functions to test schedulability with a pair of an executor and a task.
SchedulingPolicy	A function to select an executor from collection of available executors.

Class Summary

Class	Description
AntiAffinitySchedulingConstraint	Check if one of the tasks running on the executor, and the task to schedule are both in the anti-affinity group.
BatchScheduler	(CONCURRENCY) Only a single dedicated thread should use the public methods of this class.
BatchSchedulerUtils	Utlity methods regarding schedulers.
ContainerTypeAwareSchedulingConstraint	This policy find executors which has corresponding container type.
ExecutorRegistry	(WARNING) This class must be thread-safe.
FreeSlotSchedulingConstraint	This policy finds executor that has free slot for a Task.
LocalitySchedulingConstraint	This policy tries to pick the executors where the corresponding source or intermediate data for a task reside.
MinOccupancyFirstSchedulingPolicy	This policy chooses a set of Executors, on which have minimum running Tasks.
NodeShareSchedulingConstraint	This constraint is to follow ResourceSiteProperty.
PendingTaskCollectionPointer	Points to a collection of pending tasks eligible for scheduling.
SchedulingConstraintRegistry	Registry for SchedulingConstraint.
SimulatedTaskExecutor	Class for simulated task execution.
SimulationScheduler	Scheduler for simulating an execution not controlled by the runtime master.
StreamingScheduler	A simple scheduler for streaming workloads.