Module backfill_order_control

Structs

BackfillNode

BackfillOrderState

Actor done -> update fragment_id state Operator done -> update downstream operator dependency Operator’s dependencies done -> queue operator for backfill

Functions

get_nodes_with_backfill_dependencies

Get nodes with some dependencies. These should initially be paused until their dependencies are done.

Type Aliases

ActorId

This is the “global” fragment_id. The local fragment_id is namespaced by the fragment_id.