Module stream_graph

Re-exports

pub use actor::ActorGraphBuildResult;

pub use actor::ActorGraphBuilder;

pub use fragment::CompleteStreamFragmentGraph;

pub use fragment::FragmentBackfillOrder;

pub use fragment::StreamFragmentGraph;

pub use fragment::fill_snapshot_backfill_epoch;

pub use schedule::Locations;

pub use assignment::*;

Modules

actor 🔒

assignment 🔒

fragment 🔒

id 🔒

schedule 🔒

state_match

This module contains the logic for matching the internal state tables of two streaming jobs, used for replacing a streaming job (typically ALTER MV) while preserving the existing state.