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.
• 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

• mv_on_mv_dispatch_strategy 🔒