Struct MapNode 

pub struct MapNode { /* private fields */ }

Map node - field transformation.

Creates a new data structure by mapping fields from the input to new field names in the output. Supports:

• Field renaming
• Nested field extraction
• Default values for missing fields

Ports

• Input: “in” - Source data
• Output: “out” - Transformed data
• Output: “error” - Emitted on errors

Example Configuration

nodes:
  transform_user:
    type: std::map
    config:
      mappings:
        - from: $.user.full_name
          to: name
        - from: $.user.email_address
          to: email
        - from: $.metadata.created_at
          to: timestamp
          default: "unknown"
    inputs:
      - from: fetch_user.out -> in
    outputs:
      out: -> process_user.in

Implementations

impl MapNode

pub fn new(mappings: Vec<FieldMapping>) -> Self

Create a map node with the given field mappings.

pub fn empty() -> Self

Create an empty map node.

pub fn with_mapping(self, mapping: FieldMapping) -> Self

Add a field mapping.

pub fn rename(self, from: impl Into<String>, to: impl Into<String>) -> Self

Add a simple rename mapping.

pub fn with_passthrough(self) -> Self

Enable passthrough of unmapped fields.

Trait Implementations

impl Debug for MapNode

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

Formats the value using the given formatter.

impl Node for MapNode

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.