Preview an event-driven data reduction
preview_pipelineAudit a reduce/snippet pipeline by dry-running it: detect rising-edge events with a SQL predicate, build/merge pre/post windows, and see data kept - no files written.
Instructions
Dry-run an event-windowed reduction WITHOUT writing any files. Detects the rising-edge events where a SQL predicate becomes true on a topic, builds pre/post windows around them, merges overlaps, and reports how much data would be kept. Use this to audit a reduce/snippet pipeline before running it.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| args | No | ||
| path | Yes | ||
| predicate | Yes | ||
| event_topic | Yes | ||
| pre_seconds | Yes | ||
| post_seconds | No | ||
| debounce_seconds | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||