Aggregator¶

Subscribes to data and publishes per-batch column statistics on data_status under the source channel's component ref: <column>_min, _max, _avg, _sum (float64) and <column>_count (int64).

Module id: aggregator. This is what trigger data_status_val(..., 'agg=...') reads.

It publishes no telemetry of its own. Gate re-publishes the same field names after re-aggregating them and must use the same kinds.