Modules§
Structs§
- Actor
Eval Error Report - Report expression evaluation errors to the actor context.
- Barrier
Complete Result - Collect result of some barrier on current compute node. Will be reported to the meta service.
- Create
Mview Progress Reporter - The progress held by the backfill executors to report to the local barrier manager.
- Executor
Params - Local
Barrier Manager - Local
Stream Manager LocalStreamManagermanages all stream executors in this project.- Partial
Graph 🔒Id - Shared
Context - Stores the information which may be modified from the data plane.
- Stream
Environment - The global environment for task execution. The instance will be shared by every task.
Constants§
- ENABLE_
BARRIER_ AGGREGATION - If enabled, all actors will be grouped in the same tracing span within one epoch. Note that this option will significantly increase the overhead of tracing.