Interface Summary Interface Description SchedulerOnly two threads call scheduling code: RuntimeMaster thread (RMT), and SchedulerThread(ST). SchedulingConstraintFunctions to test schedulability with a pair of an executor and a task. SchedulingPolicyA function to select an executor from collection of available executors.
Class Summary Class Description AntiAffinitySchedulingConstraintCheck 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. ContainerTypeAwareSchedulingConstraintThis policy find executors which has corresponding container type. ExecutorRegistry(WARNING) This class must be thread-safe. FreeSlotSchedulingConstraintThis policy finds executor that has free slot for a Task. LocalitySchedulingConstraintThis policy tries to pick the executors where the corresponding source or intermediate data for a task reside. MinOccupancyFirstSchedulingPolicyThis policy chooses a set of Executors, on which have minimum running Tasks. NodeShareSchedulingConstraintThis constraint is to follow
PendingTaskCollectionPointerPoints to a collection of pending tasks eligible for scheduling. SchedulingConstraintRegistryRegistry for
StreamingSchedulerA simple scheduler for streaming workloads.