From ee3a6944d8433f86b95c3780eb13c3cb1b455b85 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=AA=A6=E5=87=A4=E8=99=8E?= Date: Mon, 20 May 2024 11:07:28 +0000 Subject: [PATCH] Update README.md --- .../upgrade/TSG-24.02.1/groot_stream/README.md | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) diff --git a/tsg_olap/upgrade/TSG-24.02.1/groot_stream/README.md b/tsg_olap/upgrade/TSG-24.02.1/groot_stream/README.md index a7e3c97..c94fe01 100644 --- a/tsg_olap/upgrade/TSG-24.02.1/groot_stream/README.md +++ b/tsg_olap/upgrade/TSG-24.02.1/groot_stream/README.md @@ -1 +1,17 @@ -- session_record.yaml.template +## session_record.yaml.template +- etl_session_record_kafka_to_ndc_kafka (A-DT) + - Topology: kafka_source -> etl_processor -> kafka_sink + - Data Flow: SESSION-RECORD -> SESSION-RECORD-PROCESSED +- session_record_processed_kafka_to_clickhouse(A-NDC) + - Topology: kafka_source -> clickhouse_sink + - Data Flow: SESSION-RECORD-PROCESSED -> session_record_local +- etl_session_record_kafka_to_clickhouse (B) + - Topology: kafka_source -> etl_processor -> clickhouse_sink + - Data Flow: SESSION-RECORD -> session_record_local + +## realtime_log_streaming_cn_session_record.yaml.template + +- etl_session_record_kafka_to_cn_kafka + - Topology: kafka_source -> etl_processor -> post_output_field_processor -> kafka_sink + - Data Flow: SESSION-RECORD(SESSION-RECORD-PROCESSED) -> SESSION-RECORD-CN +