Bulk ingest routes
Write batches and native bulk frames.
Flow records, windowed cell KPIs and the live state of every element, in one engine for network telemetry.
The problem
Network telemetry is relentless: flow records, interface counters and radio KPIs arrive continuously from thousands of elements, and the interesting questions are about right now. Which cells are degraded, which links are saturating, which elements went quiet.
The common stack splits this across a stream processor for windowed KPIs, a cache for element state and a warehouse for history: three systems, three schemas, and reconciliation glue that itself becomes an outage source.
You want one engine that keeps the history durable, maintains per-element current state, and computes windowed KPIs as the records arrive.
Where NYXDB fits
Architecture
Flow records and KPIs land in one table; keyed tables hold the latest state per element; STREAM SELECT over HOP or TUMBLE windows emits each KPI aggregate to NOC dashboards when its window closes.
Flow and counter records arrive through SQL, write batches or native bulk frames.
The latest row per (element, metric), in an UPSERT table.
KPIs aggregate by event time over HOP windows in STREAM SELECT, released once with EMIT AFTER WINDOW CLOSE.
Element-state changes reach NOC dashboards as they commit, with STREAM SELECT.
In practice
The examples use the same two tables on every page. See the SQL reference for full syntax.
STREAM SELECT window_start, window_end, token, COUNT() AS transfersFROM TUMBLE(transfers, transferred_at, INTERVAL 1 MINUTE)GROUP BY window_start, window_end, tokenEMIT AFTER WINDOW CLOSE;Capabilities
Write batches and native bulk frames.
Latest row per element.
Tumbling, hopping and session windows in STREAM SELECT.
Changes reach NOC dashboards as they commit, with STREAM SELECT.
Learn more