Modulesยง
Structsยง
- Build
Fragment Graph State - 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
andfragment_type
properties for current fragment. - build_
graph - generate_
fragment_ ๐graph - Generate fragment DAG from input streaming plan by their dependency.