From 05ada346db272de5d4554587b945a2bd7692564a Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Wed, 5 Feb 2025 12:53:47 +0800 Subject: [PATCH] add internal tables --- src/common/src/util/stream_graph_visitor.rs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/common/src/util/stream_graph_visitor.rs b/src/common/src/util/stream_graph_visitor.rs index f14ceadc09c42..03738744fa4a9 100644 --- a/src/common/src/util/stream_graph_visitor.rs +++ b/src/common/src/util/stream_graph_visitor.rs @@ -266,6 +266,7 @@ pub fn visit_stream_node_tables_inner( always!(node.table, "Materialize") } + // Global Approx Percentile NodeBody::GlobalApproxPercentile(node) => { always!(node.bucket_state_table, "GlobalApproxPercentileBucketState"); always!(node.count_state_table, "GlobalApproxPercentileCountState"); @@ -276,6 +277,11 @@ pub fn visit_stream_node_tables_inner( always!(node.left_table, "AsOfJoinLeft"); always!(node.right_table, "AsOfJoinRight"); } + + // Synced Log Store + NodeBody::SyncLogStore(node) => { + always!(node.log_store_table, "StreamSyncLogStore"); + } _ => {} } };