Skip to content

Commit fa424df

Browse files
forsaken628forsaken628
committed
x
1 parent 4c8011b commit fa424df

4 files changed

Lines changed: 37 additions & 37 deletions

File tree

‎src/query/sql/test-support/data/results/obfuscated/01_multi_join_avg_case_expression_physical.txt‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -4,27 +4,27 @@ Exchange
44
└── EvalScalar
55
├── output columns: [sell_mnt = 0 (#170)]
66
├── expressions: [t.sell_mnt (#169) = 0]
7-
├── estimated rows: 2966406923885887436619776.00
7+
├── estimated rows: 3018452971074898530140160.00
88
└── EvalScalar
99
├── output columns: [sell_mnt (#169)]
1010
├── expressions: [sum(CASE WHEN d.a1v = '603020' THEN 1 ELSE 0 END) (#167) / CAST(if(CAST(count(CASE WHEN d.a1v = '603020' THEN 1 ELSE 0 END) (#168) = 0 AS Boolean NULL), 1, count(CASE WHEN d.a1v = '603020' THEN 1 ELSE 0 END) (#168)) AS UInt64 NULL) + 3]
11-
├── estimated rows: 2966406923885887436619776.00
11+
├── estimated rows: 3018452971074898530140160.00
1212
└── AggregateFinal
1313
├── output columns: [sum(CASE WHEN d.a1v = '603020' THEN 1 ELSE 0 END) (#167), count(CASE WHEN d.a1v = '603020' THEN 1 ELSE 0 END) (#168), a.a0d (#0), a.a0k (#7), a.a0m (#9), c.a5m (#144)]
1414
├── group by: [a0d, a0k, a0m, a5m]
1515
├── aggregate functions: [sum(sum_arg_0), count()]
16-
├── estimated rows: 2966406923885887436619776.00
16+
├── estimated rows: 3018452971074898530140160.00
1717
└── Exchange
1818
├── output columns: [sum(CASE WHEN d.a1v = '603020' THEN 1 ELSE 0 END) (#167), count(CASE WHEN d.a1v = '603020' THEN 1 ELSE 0 END) (#168), a.a0d (#0), a.a0k (#7), a.a0m (#9), c.a5m (#144)]
1919
├── exchange type: Hash(0, 1, 2, 3)
2020
└── AggregatePartial
2121
├── group by: [a0d, a0k, a0m, a5m]
2222
├── aggregate functions: [sum(sum_arg_0), count()]
23-
├── estimated rows: 2966406923885887436619776.00
23+
├── estimated rows: 3018452971074898530140160.00
2424
└── EvalScalar
2525
├── output columns: [a.a0d (#0), a.a0k (#7), a.a0m (#9), c.a5m (#144), sum_arg_0 (#166)]
2626
├── expressions: [if(d.a1v (#154) = '603020', 1, 0)]
27-
├── estimated rows: 8899220771657662846730240.00
27+
├── estimated rows: 9055358913224696664162304.00
2828
└── HashJoin
2929
├── output columns: [a.a0d (#0), a.a0k (#7), a.a0m (#9), d.a1v (#154), c.a5m (#144)]
3030
├── join type: INNER
@@ -35,7 +35,7 @@ Exchange
3535
├── build join filters:
3636
│ ├── filter id:2, build key:b.a0k (#48), probe targets:[a.a0k (#7)@scan0], filter type:bloom,inlist,min_max
3737
│ └── filter id:3, build key:b.a0n (#50), probe targets:[a.a0n (#10)@scan0], filter type:bloom,inlist,min_max
38-
├── estimated rows: 8899220771657662846730240.00
38+
├── estimated rows: 9055358913224696664162304.00
3939
├── Exchange(Build)
4040
│ ├── output columns: [b.a0k (#48), b.a0n (#50), b.a2c (#52), b.a2k (#61)]
4141
│ ├── exchange type: Broadcast
@@ -58,7 +58,7 @@ Exchange
5858
├── filters: []
5959
├── build join filters:
6060
│ └── filter id:1, build key:c.a0m (#149), probe targets:[a.a0m (#9)@scan0], filter type:bloom,inlist,min_max
61-
├── estimated rows: 156490960961629056.00
61+
├── estimated rows: 159236617962791040.00
6262
├── Exchange(Build)
6363
│ ├── output columns: [c.a5m (#144), a0m (#149)]
6464
│ ├── exchange type: Broadcast
@@ -85,7 +85,7 @@ Exchange
8585
├── filters: []
8686
├── build join filters:
8787
│ └── filter id:0, build key:d.a5t (#151), probe targets:[a.a0l (#8)@scan0], filter type:bloom,inlist,min_max
88-
├── estimated rows: 2453851765646.43
88+
├── estimated rows: 2496904956953.83
8989
├── Exchange(Build)
9090
│ ├── output columns: [d.a5t (#151), d.a1v (#154)]
9191
│ ├── exchange type: Broadcast
@@ -109,5 +109,5 @@ Exchange
109109
├── partitions scanned: 0
110110
├── push downs: [filters: [a0c.a0d (#0) >= '20240526' and a0c.a0d (#0) <= '20250525'], limit: NONE]
111111
├── apply join filters: [#2, #3, #1, #0]
112-
└── estimated rows: 3042216421.58
112+
└── estimated rows: 3095592557.59
113113

‎src/query/sql/test-support/data/results/obfuscated/01_multi_join_sum_case_expression_physical.txt‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -4,23 +4,23 @@ Exchange
44
└── EvalScalar
55
├── output columns: [sell_mnt = 0 (#168)]
66
├── expressions: [t.sell_mnt (#167) = 0]
7-
├── estimated rows: 2966406923885887436619776.00
7+
├── estimated rows: 3018452971074898530140160.00
88
└── AggregateFinal
99
├── output columns: [sum(CASE WHEN d.a1v = '603020' THEN 1 ELSE 0 END) (#167), a.a0d (#0), a.a0k (#7), a.a0m (#9), c.a5m (#144)]
1010
├── group by: [a0d, a0k, a0m, a5m]
1111
├── aggregate functions: [sum(sum_arg_0)]
12-
├── estimated rows: 2966406923885887436619776.00
12+
├── estimated rows: 3018452971074898530140160.00
1313
└── Exchange
1414
├── output columns: [sum(CASE WHEN d.a1v = '603020' THEN 1 ELSE 0 END) (#167), a.a0d (#0), a.a0k (#7), a.a0m (#9), c.a5m (#144)]
1515
├── exchange type: Hash(0, 1, 2, 3)
1616
└── AggregatePartial
1717
├── group by: [a0d, a0k, a0m, a5m]
1818
├── aggregate functions: [sum(sum_arg_0)]
19-
├── estimated rows: 2966406923885887436619776.00
19+
├── estimated rows: 3018452971074898530140160.00
2020
└── EvalScalar
2121
├── output columns: [a.a0d (#0), a.a0k (#7), a.a0m (#9), c.a5m (#144), sum_arg_0 (#166)]
2222
├── expressions: [if(d.a1v (#154) = '603020', 1, 0)]
23-
├── estimated rows: 8899220771657662846730240.00
23+
├── estimated rows: 9055358913224696664162304.00
2424
└── HashJoin
2525
├── output columns: [a.a0d (#0), a.a0k (#7), a.a0m (#9), d.a1v (#154), c.a5m (#144)]
2626
├── join type: INNER
@@ -31,7 +31,7 @@ Exchange
3131
├── build join filters:
3232
│ ├── filter id:2, build key:b.a0k (#48), probe targets:[a.a0k (#7)@scan0], filter type:bloom,inlist,min_max
3333
│ └── filter id:3, build key:b.a0n (#50), probe targets:[a.a0n (#10)@scan0], filter type:bloom,inlist,min_max
34-
├── estimated rows: 8899220771657662846730240.00
34+
├── estimated rows: 9055358913224696664162304.00
3535
├── Exchange(Build)
3636
│ ├── output columns: [b.a0k (#48), b.a0n (#50), b.a2c (#52), b.a2k (#61)]
3737
│ ├── exchange type: Broadcast
@@ -54,7 +54,7 @@ Exchange
5454
├── filters: []
5555
├── build join filters:
5656
│ └── filter id:1, build key:c.a0m (#149), probe targets:[a.a0m (#9)@scan0], filter type:bloom,inlist,min_max
57-
├── estimated rows: 156490960961629056.00
57+
├── estimated rows: 159236617962791040.00
5858
├── Exchange(Build)
5959
│ ├── output columns: [c.a5m (#144), a0m (#149)]
6060
│ ├── exchange type: Broadcast
@@ -81,7 +81,7 @@ Exchange
8181
├── filters: []
8282
├── build join filters:
8383
│ └── filter id:0, build key:d.a5t (#151), probe targets:[a.a0l (#8)@scan0], filter type:bloom,inlist,min_max
84-
├── estimated rows: 2453851765646.43
84+
├── estimated rows: 2496904956953.83
8585
├── Exchange(Build)
8686
│ ├── output columns: [d.a5t (#151), d.a1v (#154)]
8787
│ ├── exchange type: Broadcast
@@ -105,5 +105,5 @@ Exchange
105105
├── partitions scanned: 0
106106
├── push downs: [filters: [a0c.a0d (#0) >= '20240526' and a0c.a0d (#0) <= '20250525'], limit: NONE]
107107
├── apply join filters: [#2, #3, #1, #0]
108-
└── estimated rows: 3042216421.58
108+
└── estimated rows: 3095592557.59
109109

‎tests/sqllogictests/suites/tpch/join_order.test‎

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -232,25 +232,25 @@ order by
232232
----
233233
HashJoin: INNER
234234
├── Build
235-
│ └── Scan: default.tpch_test.supplier (#3) (read rows: 10000)
235+
│ └── HashJoin: INNER
236+
│ ├── Build
237+
│ │ └── Scan: default.tpch_test.region (#5) (read rows: 5)
238+
│ └── Probe
239+
│ └── HashJoin: INNER
240+
│ ├── Build
241+
│ │ └── HashJoin: INNER
242+
│ │ ├── Build
243+
│ │ │ └── HashJoin: INNER
244+
│ │ │ ├── Build
245+
│ │ │ │ └── Scan: default.tpch_test.nation (#4) (read rows: 25)
246+
│ │ │ └── Probe
247+
│ │ │ └── Scan: default.tpch_test.supplier (#3) (read rows: 10000)
248+
│ │ └── Probe
249+
│ │ └── Scan: default.tpch_test.customer (#0) (read rows: 150000)
250+
│ └── Probe
251+
│ └── Scan: default.tpch_test.orders (#1) (read rows: 1500000)
236252
└── Probe
237-
└── HashJoin: INNER
238-
├── Build
239-
│ └── HashJoin: INNER
240-
│ ├── Build
241-
│ │ └── HashJoin: INNER
242-
│ │ ├── Build
243-
│ │ │ └── Scan: default.tpch_test.region (#5) (read rows: 5)
244-
│ │ └── Probe
245-
│ │ └── Scan: default.tpch_test.nation (#4) (read rows: 25)
246-
│ └── Probe
247-
│ └── HashJoin: INNER
248-
│ ├── Build
249-
│ │ └── Scan: default.tpch_test.customer (#0) (read rows: 150000)
250-
│ └── Probe
251-
│ └── Scan: default.tpch_test.orders (#1) (read rows: 1500000)
252-
└── Probe
253-
└── Scan: default.tpch_test.lineitem (#2) (read rows: 6001215)
253+
└── Scan: default.tpch_test.lineitem (#2) (read rows: 6001215)
254254

255255
# Q6
256256
query T

‎tests/sqllogictests/suites/tpch_iceberg/prune.test‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,11 +41,11 @@ explain select 1 from ctl.tpch.lineitem where l_orderkey < 1 or l_commitdate <
4141
EvalScalar
4242
├── output columns: [1 (#16)]
4343
├── expressions: [1]
44-
├── estimated rows: 120114.40
44+
├── estimated rows: 0.00
4545
└── Filter
4646
├── output columns: []
4747
├── filters: [lineitem.l_orderkey (#0) < 1 or lineitem.l_commitdate (#11) < '1992-01-31']
48-
├── estimated rows: 120114.40
48+
├── estimated rows: 0.00
4949
└── TableScan
5050
├── table: ctl.tpch.lineitem
5151
├── scan id: 0

0 commit comments

Comments
 (0)