Skip to main content

Content Splitting Explorer

Use the stage controls to compare the synthetic input, authored output, and configuration at each step.

How to use this explorer

Move between stages with the arrows or the numbered stage list. Each stage shows the input it receives on the left and the output it produces on the right, with the lines that changed marked. The configuration that makes the change sits below the comparison, and the final stage shows the complete pipeline.

The 5 stages in order

  1. Original Bundled Message
    Start with one synthetic message containing an array of sensor readings.
  2. Store Parent Context
    Copy selected parent fields to metadata before splitting the array.
  3. Split Array into Individual Messages
    Use the configured processor to emit one authored message per array element.
  4. Restore Parent Context
    Restore explicitly selected parent context from metadata into each authored output.
  5. Content-Based Routing
    Route the split records to named outputs from an authored temperature threshold.

Interactive pipeline

CONTENT SPLITTING

Compound-to-record transformations

Stage 1 of 5

Original Bundled Message

Start with one synthetic message containing an array of sensor readings.

0HighlightsAuthored emphasis only—not a computed diff.
Copy & download

Input

{"device_id": "sensor-001","timestamp": "2025-10-20T10:00:00Z","location": "warehouse-a","readings": [{"sensor": "temp-1", "value": 72.5, "unit": "F"},{"sensor": "temp-2", "value": 85.3, "unit": "F"},{"sensor": "temp-3", "value": 68.1, "unit": "F"}]}

Output

{"device_id": "sensor-001","timestamp": "2025-10-20T10:00:00Z","location": "warehouse-a","readings": [{"sensor": "temp-1", "value": 72.5, "unit": "F"},{"sensor": "temp-2", "value": 85.3, "unit": "F"},{"sensor": "temp-3", "value": 68.1, "unit": "F"}]}
Complete pipeline01-original-bundled-message.yaml
# Original input - bundled sensor array
input:
  http_server:
    address: 0.0.0.0:8080
    path: /sensors/bulk

# No processing yet - raw input
pipeline:
  processors: []

output:
  file:
    path: /var/log/raw-input.jsonl