Modules§
- broadcast_
channel 🔒 - channel 🔒
- consistent_
hash_ 🔒shuffle_ channel - context 🔒
- data_
chunk_ 🔒in_ channel - env 🔒
- fifo_
channel 🔒 - hash_
shuffle_ 🔒channel - task_
execution 🔒 - task_
manager 🔒
Structs§
- Batch
Environment - The global environment for task execution. The instance will be shared by every task.
- Batch
Manager BatchManageris responsible for managing all batch tasks.- Batch
Task Execution BatchTaskExecutionrepresents a single task execution.- Compute
Node Context - Batch task context on compute node.
- Shutdown
Sender - A token which can be used to signal a shutdown request.
- Shutdown
Token - A token which can be used to receive a shutdown signal.
- TaskId
- Task
Output - Task
Output Id
Enums§
- Shutdown
Msg - State
Reporter - Send batch task status (local/distributed) to frontend.
Constants§
Traits§
- Batch
Task Context - Context for batch task execution.