Struct SpatialExecutionGraph 

pub struct SpatialExecutionGraph<T> { /* private fields */ }

Mutable graph builder. Compilation freezes topology and validates transfers.

Implementations

impl<T> SpatialExecutionGraph<T>

pub fn new(pressure: BackpressurePolicy) -> Self

Creates an empty graph with explicit input watermarks.

pub fn add_node( &mut self, spec: GraphNodeSpec, operator: impl GraphOperator<T> + 'static, ) -> RuntimeResult<()>

Adds a uniquely named operator.

pub fn connect( &mut self, from: impl Into<String>, to: impl Into<String>, ) -> RuntimeResult<()>

Adds a directed data edge.

pub fn declare_transfer(&mut self, transfer: NamedTransfer)

Declares a named cross-placement transfer for one edge.

pub fn compile(self) -> RuntimeResult<CompiledSpatialGraph<T>>

Validates topology/placements and builds deterministic fusion groups.