sql/003_ingest_heartbeats.sql

     1 CREATE TABLE IF NOT EXISTS moraine.ingest_heartbeats (
     2   ts DateTime64(3) DEFAULT now64(3),
     3   host String,
     4   service_version String,
     5   queue_depth UInt64,
     6   files_active UInt32,
     7   files_watched UInt32,
     8   rows_raw_written UInt64,
     9   rows_events_written UInt64,
    10   rows_errors_written UInt64,
    11   flush_latency_ms UInt32,
    12   append_to_visible_p50_ms UInt32,
    13   append_to_visible_p95_ms UInt32,
    14   last_error String
    15 )
    16 ENGINE = MergeTree
    17 PARTITION BY toYYYYMM(ts)
    18 ORDER BY (ts, host);