risingwave_stream::task

Module env

Source

Structs§

StreamEnvironment
The global environment for task execution. The instance will be shared by every task.

Type Aliases§

WorkerNodeId 🔒