diff --git a/CN发布版本更新记录/CN-22.09/clickhouse/update-09-ck.sql b/CN发布版本更新记录/CN-22.09/clickhouse/update-09-ck.sql index 258b230..7549768 100644 --- a/CN发布版本更新记录/CN-22.09/clickhouse/update-09-ck.sql +++ b/CN发布版本更新记录/CN-22.09/clickhouse/update-09-ck.sql @@ -1,18 +1,18 @@ -ALTER table cyber_narrator_galaxy.session_record_cn_local on cluster ck_cluster add column IF NOT EXISTS common_con_duration_ms Int64 after common_end_time; -ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_cluster add column IF NOT EXISTS common_con_duration_ms Int64 after common_end_time; -ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add column IF NOT EXISTS common_con_duration_ms Int64 after common_end_time; +ALTER table cyber_narrator_galaxy.session_record_cn_local on cluster ck_cluster add column IF NOT EXISTS common_con_duration_ms Int64 after common_end_time; +ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_cluster add column IF NOT EXISTS common_con_duration_ms Int64 after common_end_time; +ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add column IF NOT EXISTS common_con_duration_ms Int64 after common_end_time; -ALTER table cyber_narrator_galaxy.session_record_cn_local on cluster ck_cluster add column IF NOT EXISTS common_app_id String after common_app_label; -ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_cluster add column IF NOT EXISTS common_app_id String after common_app_label; -ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add column IF NOT EXISTS common_app_id String after common_app_label; +ALTER table cyber_narrator_galaxy.session_record_cn_local on cluster ck_cluster add column IF NOT EXISTS common_app_id String after common_app_label; +ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_cluster add column IF NOT EXISTS common_app_id String after common_app_label; +ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add column IF NOT EXISTS common_app_id String after common_app_label; -ALTER table cyber_narrator_galaxy.session_record_cn_local on cluster ck_cluster add column IF NOT EXISTS client_zone String after domain_whois_org; -ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_cluster add column IF NOT EXISTS client_zone String after domain_whois_org; -ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add column IF NOT EXISTS client_zone String after domain_whois_org; +ALTER table cyber_narrator_galaxy.session_record_cn_local on cluster ck_cluster add column IF NOT EXISTS client_zone String after domain_whois_org; +ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_cluster add column IF NOT EXISTS client_zone String after domain_whois_org; +ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add column IF NOT EXISTS client_zone String after domain_whois_org; -ALTER table cyber_narrator_galaxy.session_record_cn_local on cluster ck_cluster add column IF NOT EXISTS server_zone String after client_idc_renter; -ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_cluster add column IF NOT EXISTS server_zone String after client_idc_renter; -ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add column IF NOT EXISTS server_zone String after client_idc_renter; +ALTER table cyber_narrator_galaxy.session_record_cn_local on cluster ck_cluster add column IF NOT EXISTS server_zone String after client_idc_renter; +ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_cluster add column IF NOT EXISTS server_zone String after client_idc_renter; +ALTER table cyber_narrator_galaxy.session_record_cn on cluster ck_query add column IF NOT EXISTS server_zone String after client_idc_renter; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ip_local ON CLUSTER ck_cluster ( @@ -33,21 +33,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ip_local ON CLUSTER ck_c traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,ip) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ip ON CLUSTER ck_cluster ( @@ -68,21 +68,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ip ON CLUSTER ck_cluster traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_ip_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ip ON CLUSTER ck_query ( @@ -103,21 +103,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ip ON CLUSTER ck_query ( traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_ip_local', rand()); @@ -140,21 +140,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_region_local ON CLUSTER traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,country,province,city) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_region ON CLUSTER ck_cluster ( @@ -176,21 +176,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_region ON CLUSTER ck_clu traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_region_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_region ON CLUSTER ck_query ( @@ -212,21 +212,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_region ON CLUSTER ck_que traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_region_local', rand()); @@ -248,21 +248,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_asn_local ON CLUSTER ck_ traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,asn,isp) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_asn ON CLUSTER ck_cluster ( @@ -283,21 +283,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_asn ON CLUSTER ck_cluste traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_asn_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_asn ON CLUSTER ck_query ( @@ -318,21 +318,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_asn ON CLUSTER ck_query traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_asn_local', rand()); @@ -353,21 +353,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_idc_renter_local ON CLUS traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,idc_renter) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_idc_renter ON CLUSTER ck_cluster ( @@ -387,21 +387,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_idc_renter ON CLUSTER ck traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_idc_renter_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_idc_renter ON CLUSTER ck_query ( @@ -421,21 +421,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_idc_renter ON CLUSTER ck traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_idc_renter_local', rand()); @@ -458,21 +458,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application_local ON CLU traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,common_app_label,app_category,app_subcategory,app_company) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application ON CLUSTER ck_cluster ( @@ -494,21 +494,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application ON CLUSTER c traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_application_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application ON CLUSTER ck_query ( @@ -530,21 +530,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_application ON CLUSTER c traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_application_local', rand()); @@ -566,21 +566,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_domain_local ON CLUSTER traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,domain,domain_category_name,domain_category_group) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_domain ON CLUSTER ck_cluster ( @@ -601,21 +601,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_domain ON CLUSTER ck_clu traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_domain_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_domain ON CLUSTER ck_query ( @@ -636,21 +636,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_domain ON CLUSTER ck_que traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_domain_local', rand()); @@ -670,21 +670,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_http_host_local ON CLUST traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,http_host) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_http_host ON CLUSTER ck_cluster ( @@ -703,21 +703,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_http_host ON CLUSTER ck_ traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_http_host_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_http_host ON CLUSTER ck_query ( @@ -736,21 +736,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_http_host ON CLUSTER ck_ traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_http_host_local', rand()); @@ -770,21 +770,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ssl_sni_local ON CLUSTER traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,ssl_sni) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ssl_sni ON CLUSTER ck_cluster ( @@ -803,21 +803,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ssl_sni ON CLUSTER ck_cl traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_ssl_sni_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ssl_sni ON CLUSTER ck_query ( @@ -836,21 +836,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_ssl_sni ON CLUSTER ck_qu traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_ssl_sni_local', rand()); @@ -871,21 +871,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol_local ON CLUSTE traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,common_l7_protocol,common_server_port) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol ON CLUSTER ck_cluster ( @@ -905,21 +905,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol ON CLUSTER ck_c traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_protocol_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol ON CLUSTER ck_query ( @@ -939,19 +939,19 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_protocol ON CLUSTER ck_q traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_protocol_local', rand()); \ No newline at end of file diff --git a/CN发布版本更新记录/CN-22.10/clickhouse/update-10-ck.sql b/CN发布版本更新记录/CN-22.10/clickhouse/update-10-ck.sql index 9028719..8c571a1 100644 --- a/CN发布版本更新记录/CN-22.10/clickhouse/update-10-ck.sql +++ b/CN发布版本更新记录/CN-22.10/clickhouse/update-10-ck.sql @@ -23,21 +23,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_link_local ON CLUSTER ck traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_link ON CLUSTER ck_cluster ( @@ -65,21 +65,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_link ON CLUSTER ck_clust traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_link_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_link ON CLUSTER ck_query ( @@ -107,21 +107,21 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_link ON CLUSTER ck_query traffic_internal_pkt Int64, traffic_through_byte Int64, traffic_through_pkt Int64, - c2s_tcp_lostlen_ratio Float64, - s2c_tcp_lostlen_ratio Float64, - tcp_lostlen_ratio Float64, - c2s_tcp_unorder_num_ratio Float64, - s2c_tcp_unorder_num_ratio Float64, - tcp_unorder_num_ratio Float64, - c2s_byte_retrans_ratio Float64, - s2c_byte_retrans_ratio Float64, - byte_retrans_ratio Float64, - c2s_pkt_retrans_ratio Float64, - s2c_pkt_retrans_ratio Float64, - pkt_retrans_ratio Float64, - avg_establish_latency_ms Float64, - avg_http_response_latency_ms Float64, - avg_ssl_con_latency_ms Float64 + c2s_tcp_lostlen_ratio Nullable(Float64), + s2c_tcp_lostlen_ratio Nullable(Float64), + tcp_lostlen_ratio Nullable(Float64), + c2s_tcp_unorder_num_ratio Nullable(Float64), + s2c_tcp_unorder_num_ratio Nullable(Float64), + tcp_unorder_num_ratio Nullable(Float64), + c2s_byte_retrans_ratio Nullable(Float64), + s2c_byte_retrans_ratio Nullable(Float64), + byte_retrans_ratio Nullable(Float64), + c2s_pkt_retrans_ratio Nullable(Float64), + s2c_pkt_retrans_ratio Nullable(Float64), + pkt_retrans_ratio Nullable(Float64), + avg_establish_latency_ms Nullable(Float64), + avg_http_response_latency_ms Nullable(Float64), + avg_ssl_con_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_link_local', rand()); @@ -138,7 +138,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_server_ip_local ON C traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,server_ip) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_server_ip ON CLUSTER ck_cluster ( @@ -154,7 +154,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_server_ip ON CLUSTER traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_server_ip_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_server_ip ON CLUSTER ck_query ( @@ -170,7 +170,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_server_ip ON CLUSTER traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_server_ip_local', rand()); @@ -184,7 +184,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qname_local ON CLUST traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,qname) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qname ON CLUSTER ck_cluster ( @@ -197,7 +197,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qname ON CLUSTER ck_ traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_qname_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qname ON CLUSTER ck_query ( @@ -210,7 +210,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qname ON CLUSTER ck_ traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_qname_local', rand()); @@ -222,7 +222,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qtype_local ON CLUST traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,qtype) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qtype ON CLUSTER ck_cluster ( @@ -233,7 +233,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qtype ON CLUSTER ck_ traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_qtype_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qtype ON CLUSTER ck_query ( @@ -244,7 +244,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_qtype ON CLUSTER ck_ traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_qtype_local', rand()); @@ -256,7 +256,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rcode_local ON CLUST traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,rcode) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rcode ON CLUSTER ck_cluster ( @@ -267,7 +267,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rcode ON CLUSTER ck_ traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rcode_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rcode ON CLUSTER ck_query ( @@ -278,7 +278,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rcode ON CLUSTER ck_ traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rcode_local', rand()); @@ -290,7 +290,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_a_local ON CLUSTE traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,rr_a) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_a ON CLUSTER ck_cluster ( @@ -301,7 +301,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_a ON CLUSTER ck_c traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_a_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_a ON CLUSTER ck_query ( @@ -312,7 +312,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_a ON CLUSTER ck_q traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_a_local', rand()); @@ -324,7 +324,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_aaaa_local ON CLU traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,rr_aaaa) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_aaaa ON CLUSTER ck_cluster ( @@ -335,7 +335,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_aaaa ON CLUSTER c traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_aaaa_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_aaaa ON CLUSTER ck_query ( @@ -346,7 +346,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_aaaa ON CLUSTER c traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_aaaa_local', rand()); @@ -358,7 +358,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_cname_local ON CL traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = MergeTree PARTITION BY toYYYYMMDD(toDate(stat_time)) ORDER BY (stat_time,rr_cname) SETTINGS index_granularity = 8192; CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_cname ON CLUSTER ck_cluster ( @@ -369,7 +369,7 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_cname ON CLUSTER traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_cname_local', rand()); CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_cname ON CLUSTER ck_query ( @@ -380,5 +380,5 @@ CREATE TABLE IF NOT EXISTS cyber_narrator_galaxy.metric_dns_rr_cname ON CLUSTER traffic_outbound_byte Int64, internal_query_num Int64, external_query_num Int64, - avg_response_latency_ms Float64 + avg_response_latency_ms Nullable(Float64) ) ENGINE = Distributed('ck_cluster', 'cyber_narrator_galaxy', 'metric_dns_rr_cname_local', rand()); \ No newline at end of file