Expand description
DAG topology data structures.
Defines DagNode, DagEdge, and StreamingDag with topological ordering,
cycle detection, and automatic channel type derivation.
Structs§
- DagEdge
- An edge represents a data flow connection between two nodes.
- DagNode
- A node in the DAG represents an operator or stage.
- EdgeId
- Unique identifier for an edge in the DAG.
- NodeId
- Unique identifier for a node in the DAG.
- Shared
Stage Metadata - Metadata for a shared intermediate stage.
- State
Partition Id - Unique identifier for a state partition.
- Streaming
Dag - The complete DAG topology.
Enums§
- DagChannel
Type - Channel type derived from DAG topology analysis.
- DagNode
Type - Classification of a DAG node for ring assignment.
- Partitioning
Strategy - Partitioning strategy for parallel operator instances.
Constants§
- MAX_
FAN_ OUT - Maximum fan-out targets per node output port.
Type Aliases§
- Partition
Fn - Custom partitioning function type.