Struct SplitNode 

pub struct SplitNode { /* private fields */ }

Split node - fan-out iterator.

Takes an array field from the input and emits each element as a separate output. This enables “for each item” processing patterns.

Ports

• Input: “in” - Data containing an array field
• Output: “out” - Emitted for each item in the array
• Output: “done” - Emitted when all items have been processed
• Output: “error” - Emitted on errors

Example Configuration

nodes:
  process_items:
    type: std::split
    config:
      field: $.items          # Array field to iterate
      mode: parallel          # sequential | parallel | batched
      batch_size: 10          # Only for batched mode
    inputs:
      - from: fetch_data.out -> in
    outputs:
      out: -> process_item.in
      done: -> finalize.in

Implementations

impl SplitNode

pub fn new(field: impl Into<String>) -> Self

Create a split node that iterates over the specified field.

pub fn sequential(field: impl Into<String>) -> Self

Create a split node with sequential processing.

pub fn parallel(field: impl Into<String>) -> Self

Create a split node with parallel processing.

pub fn batched(field: impl Into<String>, batch_size: usize) -> Self

Create a split node with batched processing.

pub fn with_mode(self, mode: SplitMode) -> Self

Set the processing mode.

Trait Implementations

impl Debug for SplitNode

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Node for SplitNode

fn info(&self) -> NodeInfo

Get metadata about this node.

fn execute<'a>( &'a self, ctx: Context, inputs: HashMap<String, RelPtr<()>>, ) -> NodeFuture<'a>

Execute the node.

fn shutdown(&self)

Called when the node is being shut down.

fn output_schema_hash(&self) -> u64

Get the schema hash for this node’s output type.