Skip to content

Commit 38edae8

Browse files
authored
feat(streaming): Temporal join part2 (risingwavelabs#8466)
1 parent e18f243 commit 38edae8

File tree

11 files changed

+847
-59
lines changed

11 files changed

+847
-59
lines changed

dashboard/proto/gen/stream_plan.ts

Lines changed: 117 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

proto/stream_plan.proto

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -289,6 +289,20 @@ message HashJoinNode {
289289
bool is_append_only = 14;
290290
}
291291

292+
message TemporalJoinNode {
293+
plan_common.JoinType join_type = 1;
294+
repeated int32 left_key = 2;
295+
repeated int32 right_key = 3;
296+
repeated bool null_safe = 4;
297+
expr.ExprNode condition = 5;
298+
// The output indices of current node
299+
repeated uint32 output_indices = 6;
300+
// The table desc of the lookup side table.
301+
plan_common.StorageTableDesc table_desc = 7;
302+
// The output indices of the lookup side table
303+
repeated uint32 table_output_indices = 8;
304+
}
305+
292306
message DynamicFilterNode {
293307
uint32 left_key = 1;
294308
// Must be one of <, <=, >, >=
@@ -531,6 +545,7 @@ message StreamNode {
531545
RowIdGenNode row_id_gen = 128;
532546
NowNode now = 129;
533547
GroupTopNNode append_only_group_top_n = 130;
548+
TemporalJoinNode temporal_join = 131;
534549
}
535550
// The id for the operator. This is local per mview.
536551
// TODO: should better be a uint32.

0 commit comments

Comments
 (0)