Wei
08/20/2025, 3:27 PMCREATE TABLE interface (
router STRING NOT NULL,
port STRING NOT NULL,
rx INT NOT NULL,
tx INT NOT NULL,
discards INT,
crc INT,
ts TIMESTAMP(3) NOT NULL,
TIME INDEX (ts)
)
WITH(
append_mode = 'true'
);
Sink table:
CREATE TABLE interface_sink (
router STRING NOT NULL,
port STRING NOT NULL,
rx INT NOT NULL,
tx INT NOT NULL,
discards INT,
crc INT,
time_window TIMESTAMP TIME INDEX,
update_at TIMESTAMP
);
I'd like to create a flow that calculates rate for tx/rx, delta for CRC/discard. Metric is sent every 30s. Occasionally, it could be missed due to various reasons.
CC: @Ruihang