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

build_graph_with_strategy

generate_fragment_graph 🔒

Generate fragment DAG from input streaming plan by their dependency.

reject_variant_in_internal_storage_key 🔒

Rejects VARIANT (including nested) in the storage pk of any internal state table. Internal tables only materialize when the plan is lowered to protobuf, so this is the single point that backstops operators whose state keys no logical checker visits.