Module state 

Structs

ApplyCommandInfo 🔒

BarrierWorkerState 🔒

The latest state of GlobalBarrierWorker after injecting the latest barrier.

RenderResult 🔒

Result of actor rendering for a create/replace streaming job.

Functions

render_actors 🔒

Render actors for a create or replace streaming job.

resolve_no_shuffle_ensembles 🔒

Derive NoShuffle edges from fragment downstream relations and resolve ensembles.

Type Aliases

ApplyCommandResult 🔒

Result tuple of apply_command: mutation, table IDs to commit, actors to create, node actors, and post-collect command.