Skip to content

pipeline dialect

← Dialect reference

Portable persistent dataflow programs over typed record streams.

Property Value
Bytecode dialect ID 0x23
Registered by default yes
Operations 9

Operations

Operation Summary
pipeline.buffer Require an independently buffered flow with SSA-defined minimum record capacity.
pipeline.def Persistent dataflow program.
pipeline.fold Fold the innermost temporal dimension of each lane's finite input record sequence using the template combining kind.
pipeline.read Read the same finite source-view record sequence for each destination lane.
pipeline.reduce Gather each source-group lane record into one target-group stage firing.
pipeline.return Terminate a pipeline definition.
pipeline.scatter Partition the leading dimension of a source view across a scheduling group.
pipeline.stage Instantiate one stage invocation per group lane.
pipeline.write Write each source-group record sequence to a destination view.