Only two threads call scheduling code: RuntimeMaster thread (RMT), and SchedulerThread(ST).
Functions to test schedulability with a pair of an executor and a task.
A function to select an executor from collection of available executors.
(CONCURRENCY) Only a single dedicated thread should use the public methods of this class.
This policy find executors which has corresponding container type.
(WARNING) This class must be thread-safe.
This policy finds executor that has free slot for a Task.
This policy tries to pick the executors where the corresponding source or intermediate data for a task reside.
This policy chooses a set of Executors, on which have minimum running Tasks.
This constraint is to follow
Points to a collection of pending tasks eligible for scheduling.
This policy aims to distribute partitions with skewed keys to different executors.
A simple scheduler for streaming workloads.
Copyright © 2019 The Apache Software Foundation. All rights reserved.