Module stream_fragmenter

Modules

• graph 🔒
• rewrite 🔒

Structs

• BuildFragmentGraphState
  The mutable state when building fragment graph.

Functions

• build_and_add_fragment 🔒
  Use the given stream_node to create a fragment and add it to graph.
• build_fragment 🔒
  Build new fragment and link dependencies by visiting children recursively, update requires_singleton and fragment_type properties for current fragment.
• build_graph
• generate_fragment_graph 🔒
  Generate fragment DAG from input streaming plan by their dependency.