feat(streaming): Temporal join part2 (risingwavelabs#8466)

Little-Wallace · Mar 10, 2023 · 38edae8 · 38edae8
1 parent e18f243
commit 38edae8
Show file tree

Hide file tree

Showing 11 changed files with 847 additions and 59 deletions.
diff --git a/dashboard/proto/gen/stream_plan.ts b/dashboard/proto/gen/stream_plan.ts
diff --git a/proto/stream_plan.proto b/proto/stream_plan.proto
@@ -289,6 +289,20 @@ message HashJoinNode {
   bool is_append_only = 14;
 }
 
+message TemporalJoinNode {
+  plan_common.JoinType join_type = 1;
+  repeated int32 left_key = 2;
+  repeated int32 right_key = 3;
+  repeated bool null_safe = 4;
+  expr.ExprNode condition = 5;
+  // The output indices of current node
+  repeated uint32 output_indices = 6;
+  // The table desc of the lookup side table.
+  plan_common.StorageTableDesc table_desc = 7;
+  // The output indices of the lookup side table
+  repeated uint32 table_output_indices = 8;
+}
+
 message DynamicFilterNode {
   uint32 left_key = 1;
   // Must be one of <, <=, >, >=
@@ -531,6 +545,7 @@ message StreamNode {
     RowIdGenNode row_id_gen = 128;
     NowNode now = 129;
     GroupTopNNode append_only_group_top_n = 130;
+    TemporalJoinNode temporal_join = 131;
   }
   // The id for the operator. This is local per mview.
   // TODO: should better be a uint32.