add internal tables

risingwavelabs · Feb 5, 2025 · 05ada34 · 05ada34
1 parent 5ad81a7
commit 05ada34
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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<F>(
                 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<F>(
                 always!(node.left_table, "AsOfJoinLeft");
                 always!(node.right_table, "AsOfJoinRight");
             }
+
+            // Synced Log Store
+            NodeBody::SyncLogStore(node) => {
+                always!(node.log_store_table, "StreamSyncLogStore");
+            }
             _ => {}
         }
     };