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 - 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.
Type Aliases§
- Actor
Handle - ActorId
- Atomic
U64Ref - Consumable
Channel Pair - Dispatcher
Id - Fragment
Id - UpDown
Actor Ids - (
upstream_actor_id,downstream_actor_id) - UpDown
Fragment Ids