Struct MergeNode 

pub struct MergeNode { /* private fields */ }

Merge node - N→1 barrier.

Waits for multiple inputs to arrive before proceeding. The output contains all merged inputs.

Ports

• Input: Multiple named inputs (e.g., “in_0”, “in_1”, “in_2”)
• Output: “out” - Merged data containing all inputs

Example Configuration

nodes:
  merge_results:
    type: std::merge
    config:
      strategy: wait_all  # or first_arrival, wait_n
      wait_count: 3       # for wait_n strategy
    inputs:
      - from: branch_a.out -> in_0
      - from: branch_b.out -> in_1
      - from: branch_c.out -> in_2

Implementations

impl MergeNode

pub fn new(expected_inputs: usize) -> Self

Create a new merge node expecting the given number of inputs.

pub fn with_strategy(expected_inputs: usize, strategy: MergeStrategy) -> Self

Create a merge node with custom strategy.

Trait Implementations

impl Debug for MergeNode

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

Formats the value using the given formatter.

impl Node for MergeNode

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.