Module fragment

Structs

BuildingFragment 🔒

The fragment in the building phase, including the [StreamFragment] from the frontend and several additional helper fields.

CompleteStreamFragmentGraph

A wrapper of StreamFragmentGraph that contains the additional information of pre-existing fragments, which are connected to the graph’s top-most or bottom-most fragments.

DownstreamExternalEdgeId 🔒

FragmentGraphDownstreamContext

FragmentGraphUpstreamContext

StreamFragmentEdge 🔒

The edge in the fragment graph.

StreamFragmentGraph

In-memory representation of a Fragment Graph, built from the [StreamFragmentGraphProto] from the frontend.

Enums

EdgeId 🔒

The ID of an edge in the fragment graph. For different types of edges, the ID will be in different variants.

EitherFragment 🔒

A fragment that is either being built or already exists. Used for generalize the logic of crate::stream::ActorGraphBuilder.

Statics

EMPTY_HASHMAP 🔒

Functions

fill_snapshot_backfill_epoch

Fill snapshot epoch for StreamScanNode of SnapshotBackfill. Return true when has change applied.

mv_on_mv_dispatch_strategy 🔒