Struct AggregateNode 

pub struct AggregateNode { /* private fields */ }

Aggregate node - numeric aggregation.

Performs aggregation operations on numeric values from:

• An array field (aggregates all elements)
• Multiple specified fields (aggregates their values)

Ports

• Input: “in” - Source data with numeric values
• Output: “out” - Object with aggregation result
• Output: “error” - Emitted on errors

Example Configuration

nodes:
  calculate_total:
    type: std::aggregate
    config:
      operation: sum
      source: $.items[*].price    # Array field
      output_field: total
    inputs:
      - from: cart.out -> in
    outputs:
      out: -> checkout.in

Implementations

impl AggregateNode

pub fn array( array_path: impl Into<String>, operation: AggregateOperation, output_field: impl Into<String>, ) -> Self

Create an aggregate node that operates on an array field.

pub fn array_field( array_path: impl Into<String>, value_field: impl Into<String>, operation: AggregateOperation, output_field: impl Into<String>, ) -> Self

Create an aggregate node that operates on an array of objects, extracting a specific field from each.

pub fn fields( fields: Vec<String>, operation: AggregateOperation, output_field: impl Into<String>, ) -> Self

Create an aggregate node that operates on multiple fields.

pub fn sum( array_path: impl Into<String>, output_field: impl Into<String>, ) -> Self

Create a sum aggregation over an array.

pub fn average( array_path: impl Into<String>, output_field: impl Into<String>, ) -> Self

Create an average aggregation over an array.

pub fn count( array_path: impl Into<String>, output_field: impl Into<String>, ) -> Self

Create a count aggregation over an array.

Trait Implementations

impl Debug for AggregateNode

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

Formats the value using the given formatter.

impl Node for AggregateNode

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.