tsg clickhouse基础字段链路号egress/ingress_link_id重命名为out/in_link_id

This commit is contained in:
houjinchuan
2023-07-20 16:35:59 +08:00
parent 3980d5b7c7
commit 6f82b8de95
3 changed files with 203 additions and 120 deletions

View File

@@ -134,8 +134,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.gtpc_record_local ON CLUSTER ck_cluster
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -251,8 +251,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.gtpc_record ON CLUSTER ck_cluster(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -363,8 +363,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.gtpc_record ON CLUSTER ck_query(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -476,8 +476,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record_local ON CLUSTER
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -732,8 +732,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record ON CLUSTER ck_cl
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -986,8 +986,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record ON CLUSTER ck_qu
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1240,8 +1240,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.transaction_record_local ON CLUSTER ck_
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1407,8 +1407,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.transaction_record ON CLUSTER ck_cluste
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1570,8 +1570,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.transaction_record ON CLUSTER ck_query(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1733,8 +1733,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.voip_record_local ON CLUSTER ck_cluster
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1858,8 +1858,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.voip_record ON CLUSTER ck_cluster(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1980,8 +1980,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.voip_record ON CLUSTER ck_query(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2102,8 +2102,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.sys_packet_capture_event_local ON CLUST
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2215,8 +2215,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.sys_packet_capture_event ON CLUSTER ck_
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2325,8 +2325,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.sys_packet_capture_event ON CLUSTER ck_
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2435,8 +2435,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.security_event_local ON CLUSTER ck_clus
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2692,8 +2692,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.security_event ON CLUSTER ck_cluster (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2946,8 +2946,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.security_event ON CLUSTER ck_query (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3201,8 +3201,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.proxy_event_local ON CLUSTER ck_cluster
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3383,8 +3383,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.proxy_event ON CLUSTER ck_cluster (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3561,8 +3561,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.proxy_event ON CLUSTER ck_query (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3739,8 +3739,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.session_record_local ON CLUSTER ck_clus
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3996,8 +3996,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.session_record ON CLUSTER ck_cluster (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -4250,8 +4250,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.session_record ON CLUSTER ck_query (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -4504,8 +4504,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.radius_record_local ON CLUSTER ck_clust
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -4639,8 +4639,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.radius_record ON CLUSTER ck_cluster (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -4770,8 +4770,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.radius_record ON CLUSTER ck_query (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -5226,8 +5226,8 @@ common_log_id UInt64,
common_recv_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_policy_id Int64,
common_user_region String,
ad_method String,
@@ -5255,8 +5255,8 @@ common_log_id UInt64,
common_recv_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_policy_id Int64,
common_user_region String,
ad_method String,
@@ -5284,8 +5284,8 @@ common_log_id UInt64,
common_recv_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_policy_id Int64,
common_user_region String,
ad_method String,

View File

@@ -132,8 +132,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.gtpc_record_local ON CLUSTER ck_cluster
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -248,8 +248,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.gtpc_record ON CLUSTER ck_cluster(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -360,8 +360,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.gtpc_record ON CLUSTER ck_query(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -473,8 +473,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record_local ON CLUSTER
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -728,8 +728,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record ON CLUSTER ck_cl
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -982,8 +982,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.interim_session_record ON CLUSTER ck_qu
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1236,8 +1236,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.transaction_record_local ON CLUSTER ck_
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1402,8 +1402,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.transaction_record ON CLUSTER ck_cluste
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1565,8 +1565,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.transaction_record ON CLUSTER ck_query(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1728,8 +1728,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.voip_record_local ON CLUSTER ck_cluster
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1852,8 +1852,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.voip_record ON CLUSTER ck_cluster(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -1974,8 +1974,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.voip_record ON CLUSTER ck_query(
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2096,8 +2096,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.sys_packet_capture_event_local ON CLUST
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2208,8 +2208,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.sys_packet_capture_event ON CLUSTER ck_
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2318,8 +2318,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.sys_packet_capture_event ON CLUSTER ck_
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2428,8 +2428,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.security_event_local ON CLUSTER ck_clus
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2684,8 +2684,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.security_event ON CLUSTER ck_cluster (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -2938,8 +2938,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.security_event ON CLUSTER ck_query (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3193,8 +3193,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.proxy_event_local ON CLUSTER ck_cluster
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3374,8 +3374,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.proxy_event ON CLUSTER ck_cluster (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3552,8 +3552,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.proxy_event ON CLUSTER ck_query (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3730,8 +3730,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.session_record_local ON CLUSTER ck_clus
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -3986,8 +3986,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.session_record ON CLUSTER ck_cluster (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -4240,8 +4240,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.session_record ON CLUSTER ck_query (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -4494,8 +4494,8 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.radius_record_local ON CLUSTER ck_clust
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -4628,8 +4628,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.radius_record ON CLUSTER ck_cluster (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -4759,8 +4759,8 @@ create table IF NOT EXISTS tsg_galaxy_v3.radius_record ON CLUSTER ck_query (
common_ingestion_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_isp String,
common_data_center String,
common_sled_ip String,
@@ -5216,8 +5216,8 @@ common_log_id UInt64,
common_recv_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_policy_id Int64,
common_user_region String,
ad_method String,
@@ -5245,8 +5245,8 @@ common_log_id UInt64,
common_recv_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_policy_id Int64,
common_user_region String,
ad_method String,
@@ -5274,8 +5274,8 @@ common_log_id UInt64,
common_recv_time Int64,
common_entrance_id Int64,
common_device_id String,
common_egress_link_id Nullable(Int64),
common_ingress_link_id Nullable(Int64),
common_out_link_id Nullable(Int64),
common_in_link_id Nullable(Int64),
common_policy_id Int64,
common_user_region String,
ad_method String,

View File

@@ -0,0 +1,83 @@
set distributed_ddl_task_timeout = 180;
ALTER table tsg_galaxy_v3.session_record_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.session_record on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.session_record on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.interim_session_record_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.interim_session_record on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.interim_session_record on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.security_event_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.security_event on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.security_event on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.proxy_event_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.proxy_event on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.proxy_event on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.transaction_record_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.transaction_record on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.transaction_record on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.sys_packet_capture_event_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.sys_packet_capture_event on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.sys_packet_capture_event on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.radius_record_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.radius_record on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.radius_record on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.gtpc_record_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.gtpc_record on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.gtpc_record on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.voip_record_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.voip_record on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.voip_record on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.active_defence_event_local on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.active_defence_event on cluster ck_cluster rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.active_defence_event on cluster ck_query rename column IF EXISTS common_egress_link_id TO common_out_link_id;
ALTER table tsg_galaxy_v3.session_record_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.session_record on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.session_record on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.interim_session_record_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.interim_session_record on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.interim_session_record on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.security_event_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.security_event on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.security_event on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.proxy_event_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.proxy_event on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.proxy_event on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.transaction_record_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.transaction_record on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.transaction_record on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.sys_packet_capture_event_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.sys_packet_capture_event on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.sys_packet_capture_event on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.radius_record_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.radius_record on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.radius_record on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.gtpc_record_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.gtpc_record on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.gtpc_record on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.voip_record_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.voip_record on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.voip_record on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.active_defence_event_local on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.active_defence_event on cluster ck_cluster rename column IF EXISTS common_ingress_link_id TO common_in_link_id;
ALTER table tsg_galaxy_v3.active_defence_event on cluster ck_query rename column IF EXISTS common_ingress_link_id TO common_in_link_id;