diff options
| author | gujinkai <[email protected]> | 2024-03-20 16:44:21 +0800 |
|---|---|---|
| committer | gujinkai <[email protected]> | 2024-03-21 14:37:47 +0800 |
| commit | fa70521afab4fcaf125eeeb895a33c3c23b75014 (patch) | |
| tree | 76131f941485ca727590d3f02187ac5799721e8b | |
| parent | b2fb3ac24da57c1f4f064df535ecc49bec16c29c (diff) | |
perf: modify some table name
| -rw-r--r-- | module-CN-pre-metrics/src/main/java/com/zdjizhi/pre/base/common/CommonConfig.java | 12 | ||||
| -rw-r--r-- | platform-schedule/src/main/resources/common.properties | 2 |
2 files changed, 7 insertions, 7 deletions
diff --git a/module-CN-pre-metrics/src/main/java/com/zdjizhi/pre/base/common/CommonConfig.java b/module-CN-pre-metrics/src/main/java/com/zdjizhi/pre/base/common/CommonConfig.java index ea5a464..2f0b2b3 100644 --- a/module-CN-pre-metrics/src/main/java/com/zdjizhi/pre/base/common/CommonConfig.java +++ b/module-CN-pre-metrics/src/main/java/com/zdjizhi/pre/base/common/CommonConfig.java @@ -55,15 +55,15 @@ public class CommonConfig { public static final ConfigOption<String> METRIC_RELATION_TOPIC = ConfigOptions.key("metric.relation.topic") .stringType() - .defaultValue("METRIC-RELATION"); + .defaultValue("RAW-SESSION-RELATION-DOMAIN-IP-APP"); public static final ConfigOption<String> METRIC_ATTRIBUTE_TOPIC = ConfigOptions.key("metric.attribute.topic") .stringType() - .defaultValue("METRIC-ATTRIBUTE"); + .defaultValue("RAW-CN-IP-DYNAMIC-ATTRIBUTE"); public static final ConfigOption<String> METRIC_SUBSCRIBER_APP_RELATION_TOPIC = ConfigOptions.key("metric.subscriber_app_relation.topic") .stringType() - .defaultValue("METRIC-RELATION-SUBSCRIBER-APP"); + .defaultValue("RAW-SESSION-RELATION-SUBSCRIBER-APP"); public static final ConfigOption<String> METRIC_IP_TABLE = ConfigOptions.key("metric.ip.table") .stringType() @@ -99,15 +99,15 @@ public class CommonConfig { public static final ConfigOption<String> METRIC_RELATION_TABLE = ConfigOptions.key("metric.relation.table") .stringType() - .defaultValue("metric_relation_local"); + .defaultValue("raw_session_relation_domain_ip_app_local"); public static final ConfigOption<String> METRIC_ATTRIBUTE_TABLE = ConfigOptions.key("metric.attribute.table") .stringType() - .defaultValue("metric_ip_dynamic_attribute_local"); + .defaultValue("raw_cn_ip_dynamic_attribute_local"); public static final ConfigOption<String> METRIC_SUBSCRIBER_APP_RELATION_TABLE = ConfigOptions.key("metric.subscriber_app_relation.table") .stringType() - .defaultValue("metric_relation_subscriber_app_local"); + .defaultValue("raw_session_relation_subscriber_app_local"); public static final ConfigOption<Integer> METRIC_OUTPUT_PARALLELISM = ConfigOptions.key("metric.output.parallelism") .intType() diff --git a/platform-schedule/src/main/resources/common.properties b/platform-schedule/src/main/resources/common.properties index a9367ae..0ed8dbe 100644 --- a/platform-schedule/src/main/resources/common.properties +++ b/platform-schedule/src/main/resources/common.properties @@ -1,5 +1,5 @@ # ???? -stream.execution.job.name=CN-STREAM-PROCESSING-PLATFORM +stream.execution.job.name=cn_stream_processing_platform # ????? stream.execution.environment.parallelism=2 # kafka source??? |