Module stream_fragmenter

Modules

graph 🔒

parallelism 🔒

rewrite 🔒

Structs

BuildFragmentGraphState

The mutable state when building fragment graph.

Enums

GraphJobType

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.