修改source_port和destination_port类型为Nullable(Int32)

This commit is contained in:
wangkuan
2024-05-24 10:18:24 +08:00
parent e1aa09eaec
commit 32a798c2e4
2 changed files with 12 additions and 12 deletions

View File

@@ -4282,9 +4282,9 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record_local on clus
device_group String,
traffic_link_id Int32,
source_ip String,
source_port Int32,
source_port Nullable(Int32),
destination_ip String,
destination_port Int32,
destination_port Nullable(Int32),
packet String,
packet_length Int32,
measurements String
@@ -4303,9 +4303,9 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record on cluster ck
device_group String,
traffic_link_id Int32,
source_ip String,
source_port Int32,
source_port Nullable(Int32),
destination_ip String,
destination_port Int32,
destination_port Nullable(Int32),
packet String,
packet_length Int32,
measurements String
@@ -4325,9 +4325,9 @@ ENGINE = Distributed('ck_cluster',
device_group String,
traffic_link_id Int32,
source_ip String,
source_port Int32,
source_port Nullable(Int32),
destination_ip String,
destination_port Int32,
destination_port Nullable(Int32),
packet String,
packet_length Int32,
measurements String

View File

@@ -13,9 +13,9 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record_local on clus
device_group String,
traffic_link_id Int32,
source_ip String,
source_port Int32,
source_port Nullable(Int32),
destination_ip String,
destination_port Int32,
destination_port Nullable(Int32),
packet String,
packet_length Int32,
measurements String
@@ -34,9 +34,9 @@ CREATE TABLE IF NOT EXISTS tsg_galaxy_v3.datapath_telemetry_record on cluster ck
device_group String,
traffic_link_id Int32,
source_ip String,
source_port Int32,
source_port Nullable(Int32),
destination_ip String,
destination_port Int32,
destination_port Nullable(Int32),
packet String,
packet_length Int32,
measurements String
@@ -56,9 +56,9 @@ ENGINE = Distributed('ck_cluster',
device_group String,
traffic_link_id Int32,
source_ip String,
source_port Int32,
source_port Nullable(Int32),
destination_ip String,
destination_port Int32,
destination_port Nullable(Int32),
packet String,
packet_length Int32,
measurements String