Module task

Modules

• await_tree_key
• barrier_manager 🔒
• env 🔒
• stream_manager 🔒

Structs

• ActorEvalErrorReport
  Report expression evaluation errors to the actor context.
• BarrierCompleteResult
  Collect result of some barrier on current compute node. Will be reported to the meta service.
• CreateMviewProgressReporter
  The progress held by the backfill executors to report to the local barrier manager.
• ExecutorParams
• LocalBarrierManager
• LocalStreamManager
  LocalStreamManager manages all stream executors in this project.
• PartialGraphId 🔒
• SharedContext
  Stores the information which may be modified from the data plane.
• StreamEnvironment
  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.

Functions

• unique_executor_id
  Generate a globally unique executor id.
• unique_operator_id
  Generate a globally unique operator id.

Type Aliases

• ActorHandle
• ActorId
• AtomicU64Ref
• ConsumableChannelPair
• DispatcherId
• FragmentId
• UpDownActorIds
• UpDownFragmentIds