diff --git a/src/frontend/planner_test/tests/testdata/nexmark_source.yaml b/src/frontend/planner_test/tests/testdata/nexmark_source.yaml index c1b09c88371f2..fb637bba603dc 100644 --- a/src/frontend/planner_test/tests/testdata/nexmark_source.yaml +++ b/src/frontend/planner_test/tests/testdata/nexmark_source.yaml @@ -355,7 +355,7 @@ | └─StreamHopWindow { time_col: date_time, slide: 00:00:02, size: 00:00:10, output: [auction, window_start, _row_id] } | └─StreamFilter { predicate: IsNotNull(date_time) } | └─StreamProject { exprs: [auction, date_time, _row_id] } - | └─StreamShare { id = 1313 } + | └─StreamShare { id = 919 } | └─StreamProject { exprs: [auction, date_time, _row_id] } | └─StreamFilter { predicate: IsNotNull(date_time) } | └─StreamRowIdGen { row_id_index: 7 } @@ -369,7 +369,7 @@ └─StreamHopWindow { time_col: date_time, slide: 00:00:02, size: 00:00:10, output: [auction, window_start, _row_id] } └─StreamFilter { predicate: IsNotNull(date_time) } └─StreamProject { exprs: [auction, date_time, _row_id] } - └─StreamShare { id = 1313 } + └─StreamShare { id = 919 } └─StreamProject { exprs: [auction, date_time, _row_id] } └─StreamFilter { predicate: IsNotNull(date_time) } └─StreamRowIdGen { row_id_index: 7 } diff --git a/src/frontend/planner_test/tests/testdata/predicate_pushdown.yaml b/src/frontend/planner_test/tests/testdata/predicate_pushdown.yaml index 67b74f9a3f5fd..3ae0faf0d7e96 100644 --- a/src/frontend/planner_test/tests/testdata/predicate_pushdown.yaml +++ b/src/frontend/planner_test/tests/testdata/predicate_pushdown.yaml @@ -54,7 +54,7 @@ logical_plan: | LogicalProject { exprs: [t.v1, t.v2, t.v3, t.v4, t.ts, window_start, window_end] } └─LogicalFilter { predicate: (t.v1 = 10:Int32) AND (t.v2 = 20:Int32) AND (t.v3 = 30:Int32) AND (t.ts >= '1997-07-01':Date) AND (window_start >= '1997-07-02':Date) AND (window_end >= '1997-07-03':Date) AND (window_start >= (t.ts + '1 day':Interval)) AND (window_end > (t.ts + '4 days':Interval)) } - └─LogicalShare { id = 11 } + └─LogicalShare { id = 5 } └─LogicalProject { exprs: [t.v1, t.v2, t.v3, t.v4, t.ts, window_start, window_end] } └─LogicalHopWindow { time_col: t.ts, slide: 1 day, size: 3 days, output: all } └─LogicalFilter { predicate: IsNotNull(t.ts) } @@ -71,7 +71,7 @@ logical_plan: | LogicalProject { exprs: [window_end, t.v4, t.v2] } └─LogicalFilter { predicate: (window_end > '2022-01-01':Date) AND (t.v4 = 10:Int32) AND (t.v2 > 20:Int32) } - └─LogicalShare { id = 11 } + └─LogicalShare { id = 5 } └─LogicalProject { exprs: [window_end, t.v4, t.v2] } └─LogicalHopWindow { time_col: t.ts, slide: 1 day, size: 3 days, output: all } └─LogicalFilter { predicate: IsNotNull(t.ts) } diff --git a/src/frontend/planner_test/tests/testdata/share.yaml b/src/frontend/planner_test/tests/testdata/share.yaml index c1ab66c60ca33..1d5e5dfaebe24 100644 --- a/src/frontend/planner_test/tests/testdata/share.yaml +++ b/src/frontend/planner_test/tests/testdata/share.yaml @@ -130,7 +130,7 @@ | └─StreamHopWindow { time_col: date_time, slide: 00:00:02, size: 00:00:10, output: [auction, window_start, _row_id] } | └─StreamFilter { predicate: IsNotNull(date_time) } | └─StreamProject { exprs: [auction, date_time, _row_id] } - | └─StreamShare { id = 1313 } + | └─StreamShare { id = 919 } | └─StreamProject { exprs: [auction, date_time, _row_id] } | └─StreamFilter { predicate: IsNotNull(date_time) } | └─StreamRowIdGen { row_id_index: 7 } @@ -144,7 +144,7 @@ └─StreamHopWindow { time_col: date_time, slide: 00:00:02, size: 00:00:10, output: [auction, window_start, _row_id] } └─StreamFilter { predicate: IsNotNull(date_time) } └─StreamProject { exprs: [auction, date_time, _row_id] } - └─StreamShare { id = 1313 } + └─StreamShare { id = 919 } └─StreamProject { exprs: [auction, date_time, _row_id] } └─StreamFilter { predicate: IsNotNull(date_time) } └─StreamRowIdGen { row_id_index: 7 } diff --git a/src/frontend/planner_test/tests/testdata/subquery.yaml b/src/frontend/planner_test/tests/testdata/subquery.yaml index f95fff487b388..0bca90173b309 100644 --- a/src/frontend/planner_test/tests/testdata/subquery.yaml +++ b/src/frontend/planner_test/tests/testdata/subquery.yaml @@ -218,14 +218,14 @@ └─LogicalValues { rows: [[]], schema: Schema { fields: [] } } optimized_logical_plan: | LogicalJoin { type: LeftSemi, on: IsNotDistinctFrom(auction.date_time, auction.date_time), output: all } - ├─LogicalShare { id = 248 } + ├─LogicalShare { id = 125 } | └─LogicalHopWindow { time_col: auction.date_time, slide: 00:00:01, size: 01:00:00, output: all } | └─LogicalScan { table: auction, columns: [auction.date_time], predicate: IsNotNull(auction.date_time) } └─LogicalProject { exprs: [auction.date_time] } └─LogicalAgg { group_key: [auction.date_time, auction.date_time], aggs: [] } └─LogicalJoin { type: Inner, on: true, output: [auction.date_time, auction.date_time] } ├─LogicalAgg { group_key: [auction.date_time], aggs: [] } - | └─LogicalShare { id = 248 } + | └─LogicalShare { id = 125 } | └─LogicalHopWindow { time_col: auction.date_time, slide: 00:00:01, size: 01:00:00, output: all } | └─LogicalScan { table: auction, columns: [auction.date_time], predicate: IsNotNull(auction.date_time) } └─LogicalValues { rows: [[]], schema: Schema { fields: [] } } diff --git a/src/frontend/planner_test/tests/testdata/time_window.yaml b/src/frontend/planner_test/tests/testdata/time_window.yaml index 8cf49d2e4d0c6..817d008bd656d 100644 --- a/src/frontend/planner_test/tests/testdata/time_window.yaml +++ b/src/frontend/planner_test/tests/testdata/time_window.yaml @@ -186,7 +186,7 @@ LogicalProject { exprs: [t1.id, t1.v1, t1.created_at, window_start, window_end] } └─LogicalHopWindow { time_col: t1.created_at, slide: 1 day, size: 3 days, output: all } └─LogicalFilter { predicate: IsNotNull(t1.created_at) } - └─LogicalShare { id = 10 } + └─LogicalShare { id = 4 } └─LogicalProject { exprs: [t1.id, t1.v1, t1.created_at] } └─LogicalFilter { predicate: (t1.v1 >= 10:Int32) } └─LogicalScan { table: t1, columns: [t1.id, t1.v1, t1.created_at, t1._row_id] }