risingwave_batch::task

Module task_execution

Source

Structs§

BatchTaskExecution
BatchTaskExecution represents a single task execution.
ShutdownSender
A token which can be used to signal a shutdown request.
ShutdownToken
A token which can be used to receive a shutdown signal.
TaskId
TaskOutput
TaskOutputId

Enums§

ShutdownMsg
StateReporter
Send batch task status (local/distributed) to frontend.

Constants§

TASK_STATUS_BUFFER_SIZE