Skip to content

[GLUTEN-12375][VL][UT] Do not normalize string literals as ExprIds in plan stability suites #12521

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
PerumalsamyR wants to merge 1 commit into
base: main
Choose a base branch
from
Open

[GLUTEN-12375][VL][UT] Do not normalize string literals as ExprIds in plan stability suites #12521

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
58 changes: 29 additions & 29 deletions ...n-ut/spark40/src/test/resources/backends-velox/gluten-tpch-plan-stability/q16/explain.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -82,12 +82,12 @@ Join condition: None
Output [4]: [p_partkey#5, p_brand#6, p_type#7, p_size#8]
Batched: true
Location: InMemoryFileIndex [{warehouse_dir}/part]
PushedFilters: [IsNotNull(p_brand), IsNotNull(p_type), Not(EqualTo(p_brand,Brand#9)), Not(StringStartsWith(p_type,MEDIUM POLISHED)), In(p_size, [14,19,23,3,36,45,49,9]), IsNotNull(p_partkey)]
PushedFilters: [IsNotNull(p_brand), IsNotNull(p_type), Not(EqualTo(p_brand,Brand#45)), Not(StringStartsWith(p_type,MEDIUM POLISHED)), In(p_size, [14,19,23,3,36,45,49,9]), IsNotNull(p_partkey)]
ReadSchema: struct<p_partkey:bigint,p_brand:string,p_type:string,p_size:int>

(12) FilterExecTransformer
Input [4]: [p_partkey#5, p_brand#6, p_type#7, p_size#8]
Arguments: (((((isnotnull(p_brand#6) AND isnotnull(p_type#7)) AND NOT (p_brand#6 = Brand#9)) AND NOT StartsWith(p_type#7, MEDIUM POLISHED)) AND p_size#8 IN (49,14,23,45,19,3,36,9)) AND isnotnull(p_partkey#5))
Arguments: (((((isnotnull(p_brand#6) AND isnotnull(p_type#7)) AND NOT (p_brand#6 = Brand#45)) AND NOT StartsWith(p_type#7, MEDIUM POLISHED)) AND p_size#8 IN (49,14,23,45,19,3,36,9)) AND isnotnull(p_partkey#5))

(13) WholeStageCodegenTransformer (2)
Input [4]: [p_partkey#5, p_brand#6, p_type#7, p_size#8]
Expand Down Expand Up @@ -121,19 +121,19 @@ Aggregate Attributes: []
Results [4]: [p_brand#6, p_type#7, p_size#8, ps_suppkey#2]

(20) ProjectExecTransformer
Output [5]: [hash(p_brand#6, p_type#7, p_size#8, ps_suppkey#2, 42) AS hash_partition_key#10, p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Output [5]: [hash(p_brand#6, p_type#7, p_size#8, ps_suppkey#2, 42) AS hash_partition_key#9, p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Input [4]: [p_brand#6, p_type#7, p_size#8, ps_suppkey#2]

(21) WholeStageCodegenTransformer (3)
Input [5]: [hash_partition_key#10, p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Input [5]: [hash_partition_key#9, p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Arguments: false

(22) VeloxResizeBatches
Input [5]: [hash_partition_key#10, p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Input [5]: [hash_partition_key#9, p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Arguments: 1024, 2147483647, 10485760

(23) ColumnarExchange
Input [5]: [hash_partition_key#10, p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Input [5]: [hash_partition_key#9, p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Arguments: hashpartitioning(p_brand#6, p_type#7, p_size#8, ps_suppkey#2, 1), ENSURE_REQUIREMENTS, [p_brand#6, p_type#7, p_size#8, ps_suppkey#2], [plan_id=3], [shuffle_writer_type=hash]

(24) InputAdapter
Expand All @@ -153,64 +153,64 @@ Results [4]: [p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Input [4]: [p_brand#6, p_type#7, p_size#8, ps_suppkey#2]
Keys [3]: [p_brand#6, p_type#7, p_size#8]
Functions [1]: [partial_count(distinct ps_suppkey#2)]
Aggregate Attributes [1]: [count(ps_suppkey#2)#11]
Results [4]: [p_brand#6, p_type#7, p_size#8, count#12]
Aggregate Attributes [1]: [count(ps_suppkey#2)#10]
Results [4]: [p_brand#6, p_type#7, p_size#8, count#11]

(28) ProjectExecTransformer
Output [5]: [hash(p_brand#6, p_type#7, p_size#8, 42) AS hash_partition_key#13, p_brand#6, p_type#7, p_size#8, count#12]
Input [4]: [p_brand#6, p_type#7, p_size#8, count#12]
Output [5]: [hash(p_brand#6, p_type#7, p_size#8, 42) AS hash_partition_key#12, p_brand#6, p_type#7, p_size#8, count#11]
Input [4]: [p_brand#6, p_type#7, p_size#8, count#11]

(29) WholeStageCodegenTransformer (4)
Input [5]: [hash_partition_key#13, p_brand#6, p_type#7, p_size#8, count#12]
Input [5]: [hash_partition_key#12, p_brand#6, p_type#7, p_size#8, count#11]
Arguments: false

(30) VeloxResizeBatches
Input [5]: [hash_partition_key#13, p_brand#6, p_type#7, p_size#8, count#12]
Input [5]: [hash_partition_key#12, p_brand#6, p_type#7, p_size#8, count#11]
Arguments: 1024, 2147483647, 10485760

(31) ColumnarExchange
Input [5]: [hash_partition_key#13, p_brand#6, p_type#7, p_size#8, count#12]
Arguments: hashpartitioning(p_brand#6, p_type#7, p_size#8, 1), ENSURE_REQUIREMENTS, [p_brand#6, p_type#7, p_size#8, count#12], [plan_id=4], [shuffle_writer_type=hash]
Input [5]: [hash_partition_key#12, p_brand#6, p_type#7, p_size#8, count#11]
Arguments: hashpartitioning(p_brand#6, p_type#7, p_size#8, 1), ENSURE_REQUIREMENTS, [p_brand#6, p_type#7, p_size#8, count#11], [plan_id=4], [shuffle_writer_type=hash]

(32) InputAdapter
Input [4]: [p_brand#6, p_type#7, p_size#8, count#12]
Input [4]: [p_brand#6, p_type#7, p_size#8, count#11]

(33) InputIteratorTransformer
Input [4]: [p_brand#6, p_type#7, p_size#8, count#12]
Input [4]: [p_brand#6, p_type#7, p_size#8, count#11]

(34) RegularHashAggregateExecTransformer
Input [4]: [p_brand#6, p_type#7, p_size#8, count#12]
Input [4]: [p_brand#6, p_type#7, p_size#8, count#11]
Keys [3]: [p_brand#6, p_type#7, p_size#8]
Functions [1]: [count(distinct ps_suppkey#2)]
Aggregate Attributes [1]: [count(ps_suppkey#2)#11]
Results [4]: [p_brand#6, p_type#7, p_size#8, count(ps_suppkey#2)#11 AS supplier_cnt#14]
Aggregate Attributes [1]: [count(ps_suppkey#2)#10]
Results [4]: [p_brand#6, p_type#7, p_size#8, count(ps_suppkey#2)#10 AS supplier_cnt#13]

(35) WholeStageCodegenTransformer (5)
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#14]
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#13]
Arguments: false

(36) VeloxResizeBatches
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#14]
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#13]
Arguments: 1024, 2147483647, 10485760

(37) ColumnarExchange
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#14]
Arguments: rangepartitioning(supplier_cnt#14 DESC NULLS LAST, p_brand#6 ASC NULLS FIRST, p_type#7 ASC NULLS FIRST, p_size#8 ASC NULLS FIRST, 1), ENSURE_REQUIREMENTS, [plan_id=5], [shuffle_writer_type=hash]
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#13]
Arguments: rangepartitioning(supplier_cnt#13 DESC NULLS LAST, p_brand#6 ASC NULLS FIRST, p_type#7 ASC NULLS FIRST, p_size#8 ASC NULLS FIRST, 1), ENSURE_REQUIREMENTS, [plan_id=5], [shuffle_writer_type=hash]

(38) InputAdapter
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#14]
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#13]

(39) InputIteratorTransformer
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#14]
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#13]

(40) SortExecTransformer
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#14]
Arguments: [supplier_cnt#14 DESC NULLS LAST, p_brand#6 ASC NULLS FIRST, p_type#7 ASC NULLS FIRST, p_size#8 ASC NULLS FIRST], true, 0
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#13]
Arguments: [supplier_cnt#13 DESC NULLS LAST, p_brand#6 ASC NULLS FIRST, p_type#7 ASC NULLS FIRST, p_size#8 ASC NULLS FIRST], true, 0

(41) WholeStageCodegenTransformer (6)
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#14]
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#13]
Arguments: false

(42) VeloxColumnarToRow
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#14]
Input [4]: [p_brand#6, p_type#7, p_size#8, supplier_cnt#13]

100 changes: 50 additions & 50 deletions ...n-ut/spark40/src/test/resources/backends-velox/gluten-tpch-plan-stability/q17/explain.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -47,12 +47,12 @@ Arguments: (isnotnull(l_partkey#1) AND isnotnull(l_quantity#2))
Output [3]: [p_partkey#4, p_brand#5, p_container#6]
Batched: true
Location: InMemoryFileIndex [{warehouse_dir}/part]
PushedFilters: [IsNotNull(p_brand), IsNotNull(p_container), EqualTo(p_brand,Brand#7), EqualTo(p_container,MED BOX), IsNotNull(p_partkey)]
PushedFilters: [IsNotNull(p_brand), IsNotNull(p_container), EqualTo(p_brand,Brand#23), EqualTo(p_container,MED BOX), IsNotNull(p_partkey)]
ReadSchema: struct<p_partkey:bigint,p_brand:string,p_container:string>

(4) FilterExecTransformer
Input [3]: [p_partkey#4, p_brand#5, p_container#6]
Arguments: ((((isnotnull(p_brand#5) AND isnotnull(p_container#6)) AND (p_brand#5 = Brand#7)) AND (p_container#6 = MED BOX)) AND isnotnull(p_partkey#4))
Arguments: ((((isnotnull(p_brand#5) AND isnotnull(p_container#6)) AND (p_brand#5 = Brand#23)) AND (p_container#6 = MED BOX)) AND isnotnull(p_partkey#4))

(5) ProjectExecTransformer
Output [1]: [p_partkey#4]
Expand Down Expand Up @@ -83,128 +83,128 @@ Output [3]: [l_quantity#2, l_extendedprice#3, p_partkey#4]
Input [4]: [l_partkey#1, l_quantity#2, l_extendedprice#3, p_partkey#4]

(12) FileSourceScanExecTransformer parquet spark_catalog.default.lineitem
Output [2]: [l_partkey#8, l_quantity#9]
Output [2]: [l_partkey#7, l_quantity#8]
Batched: true
Location: InMemoryFileIndex [{warehouse_dir}/lineitem]
PushedFilters: [IsNotNull(l_partkey)]
ReadSchema: struct<l_partkey:bigint,l_quantity:decimal(10,0)>

(13) FilterExecTransformer
Input [2]: [l_partkey#8, l_quantity#9]
Arguments: isnotnull(l_partkey#8)
Input [2]: [l_partkey#7, l_quantity#8]
Arguments: isnotnull(l_partkey#7)

(14) ProjectExecTransformer
Output [2]: [l_partkey#8, UnscaledValue(l_quantity#9) AS _pre_1#10]
Input [2]: [l_partkey#8, l_quantity#9]
Output [2]: [l_partkey#7, UnscaledValue(l_quantity#8) AS _pre_1#9]
Input [2]: [l_partkey#7, l_quantity#8]

(15) FlushableHashAggregateExecTransformer
Input [2]: [l_partkey#8, _pre_1#10]
Keys [1]: [l_partkey#8]
Functions [1]: [partial_avg(_pre_1#10)]
Aggregate Attributes [2]: [sum#11, count#12]
Results [3]: [l_partkey#8, sum#13, count#14]
Input [2]: [l_partkey#7, _pre_1#9]
Keys [1]: [l_partkey#7]
Functions [1]: [partial_avg(_pre_1#9)]
Aggregate Attributes [2]: [sum#10, count#11]
Results [3]: [l_partkey#7, sum#12, count#13]

(16) ProjectExecTransformer
Output [4]: [hash(l_partkey#8, 42) AS hash_partition_key#15, l_partkey#8, sum#13, count#14]
Input [3]: [l_partkey#8, sum#13, count#14]
Output [4]: [hash(l_partkey#7, 42) AS hash_partition_key#14, l_partkey#7, sum#12, count#13]
Input [3]: [l_partkey#7, sum#12, count#13]

(17) WholeStageCodegenTransformer (2)
Input [4]: [hash_partition_key#15, l_partkey#8, sum#13, count#14]
Input [4]: [hash_partition_key#14, l_partkey#7, sum#12, count#13]
Arguments: false

(18) VeloxResizeBatches
Input [4]: [hash_partition_key#15, l_partkey#8, sum#13, count#14]
Input [4]: [hash_partition_key#14, l_partkey#7, sum#12, count#13]
Arguments: 1024, 2147483647, 10485760

(19) ColumnarExchange
Input [4]: [hash_partition_key#15, l_partkey#8, sum#13, count#14]
Arguments: hashpartitioning(l_partkey#8, 1), ENSURE_REQUIREMENTS, [l_partkey#8, sum#13, count#14], [plan_id=2], [shuffle_writer_type=hash]
Input [4]: [hash_partition_key#14, l_partkey#7, sum#12, count#13]
Arguments: hashpartitioning(l_partkey#7, 1), ENSURE_REQUIREMENTS, [l_partkey#7, sum#12, count#13], [plan_id=2], [shuffle_writer_type=hash]

(20) InputAdapter
Input [3]: [l_partkey#8, sum#13, count#14]
Input [3]: [l_partkey#7, sum#12, count#13]

(21) InputIteratorTransformer
Input [3]: [l_partkey#8, sum#13, count#14]
Input [3]: [l_partkey#7, sum#12, count#13]

(22) RegularHashAggregateExecTransformer
Input [3]: [l_partkey#8, sum#13, count#14]
Keys [1]: [l_partkey#8]
Functions [1]: [avg(UnscaledValue(l_quantity#9))]
Aggregate Attributes [1]: [avg(UnscaledValue(l_quantity#9))#16]
Results [2]: [l_partkey#8, avg(UnscaledValue(l_quantity#9))#16]
Input [3]: [l_partkey#7, sum#12, count#13]
Keys [1]: [l_partkey#7]
Functions [1]: [avg(UnscaledValue(l_quantity#8))]
Aggregate Attributes [1]: [avg(UnscaledValue(l_quantity#8))#15]
Results [2]: [l_partkey#7, avg(UnscaledValue(l_quantity#8))#15]

(23) ProjectExecTransformer
Output [2]: [(0.2 * cast((avg(UnscaledValue(l_quantity#9))#16 / 1.0) as decimal(14,4))) AS (0.2 * avg(l_quantity))#17, l_partkey#8]
Input [2]: [l_partkey#8, avg(UnscaledValue(l_quantity#9))#16]
Output [2]: [(0.2 * cast((avg(UnscaledValue(l_quantity#8))#15 / 1.0) as decimal(14,4))) AS (0.2 * avg(l_quantity))#16, l_partkey#7]
Input [2]: [l_partkey#7, avg(UnscaledValue(l_quantity#8))#15]

(24) FilterExecTransformer
Input [2]: [(0.2 * avg(l_quantity))#17, l_partkey#8]
Arguments: isnotnull((0.2 * avg(l_quantity))#17)
Input [2]: [(0.2 * avg(l_quantity))#16, l_partkey#7]
Arguments: isnotnull((0.2 * avg(l_quantity))#16)

(25) WholeStageCodegenTransformer (3)
Input [2]: [(0.2 * avg(l_quantity))#17, l_partkey#8]
Input [2]: [(0.2 * avg(l_quantity))#16, l_partkey#7]
Arguments: false

(26) ColumnarBroadcastExchange
Input [2]: [(0.2 * avg(l_quantity))#17, l_partkey#8]
Input [2]: [(0.2 * avg(l_quantity))#16, l_partkey#7]
Arguments: HashedRelationBroadcastMode(List(input[1, bigint, true]),false), [plan_id=3]

(27) InputAdapter
Input [2]: [(0.2 * avg(l_quantity))#17, l_partkey#8]
Input [2]: [(0.2 * avg(l_quantity))#16, l_partkey#7]

(28) InputIteratorTransformer
Input [2]: [(0.2 * avg(l_quantity))#17, l_partkey#8]
Input [2]: [(0.2 * avg(l_quantity))#16, l_partkey#7]

(29) BroadcastHashJoinExecTransformer
Left keys [1]: [p_partkey#4]
Right keys [1]: [l_partkey#8]
Right keys [1]: [l_partkey#7]
Join type: Inner
Join condition: (cast(l_quantity#2 as decimal(16,5)) < (0.2 * avg(l_quantity))#17)
Join condition: (cast(l_quantity#2 as decimal(16,5)) < (0.2 * avg(l_quantity))#16)

(30) ProjectExecTransformer
Output [1]: [l_extendedprice#3]
Input [5]: [l_quantity#2, l_extendedprice#3, p_partkey#4, (0.2 * avg(l_quantity))#17, l_partkey#8]
Input [5]: [l_quantity#2, l_extendedprice#3, p_partkey#4, (0.2 * avg(l_quantity))#16, l_partkey#7]

(31) FlushableHashAggregateExecTransformer
Input [1]: [l_extendedprice#3]
Keys: []
Functions [1]: [partial_sum(l_extendedprice#3)]
Aggregate Attributes [2]: [sum#18, isEmpty#19]
Results [2]: [sum#20, isEmpty#21]
Aggregate Attributes [2]: [sum#17, isEmpty#18]
Results [2]: [sum#19, isEmpty#20]

(32) WholeStageCodegenTransformer (4)
Input [2]: [sum#20, isEmpty#21]
Input [2]: [sum#19, isEmpty#20]
Arguments: false

(33) VeloxResizeBatches
Input [2]: [sum#20, isEmpty#21]
Input [2]: [sum#19, isEmpty#20]
Arguments: 1024, 2147483647, 10485760

(34) ColumnarExchange
Input [2]: [sum#20, isEmpty#21]
Input [2]: [sum#19, isEmpty#20]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=4], [shuffle_writer_type=hash]

(35) InputAdapter
Input [2]: [sum#20, isEmpty#21]
Input [2]: [sum#19, isEmpty#20]

(36) InputIteratorTransformer
Input [2]: [sum#20, isEmpty#21]
Input [2]: [sum#19, isEmpty#20]

(37) RegularHashAggregateExecTransformer
Input [2]: [sum#20, isEmpty#21]
Input [2]: [sum#19, isEmpty#20]
Keys: []
Functions [1]: [sum(l_extendedprice#3)]
Aggregate Attributes [1]: [sum(l_extendedprice#3)#22]
Results [1]: [sum(l_extendedprice#3)#22]
Aggregate Attributes [1]: [sum(l_extendedprice#3)#21]
Results [1]: [sum(l_extendedprice#3)#21]

(38) ProjectExecTransformer
Output [1]: [(sum(l_extendedprice#3)#22 / 7.0) AS avg_yearly#23]
Input [1]: [sum(l_extendedprice#3)#22]
Output [1]: [(sum(l_extendedprice#3)#21 / 7.0) AS avg_yearly#22]
Input [1]: [sum(l_extendedprice#3)#21]

(39) WholeStageCodegenTransformer (5)
Input [1]: [avg_yearly#23]
Input [1]: [avg_yearly#22]
Arguments: false

(40) VeloxColumnarToRow
Input [1]: [avg_yearly#23]
Input [1]: [avg_yearly#22]

36 changes: 18 additions & 18 deletions ...n-ut/spark40/src/test/resources/backends-velox/gluten-tpch-plan-stability/q19/explain.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,12 +35,12 @@ Input [6]: [l_partkey#1, l_quantity#2, l_extendedprice#3, l_discount#4, l_shipin
Output [4]: [p_partkey#7, p_brand#8, p_size#9, p_container#10]
Batched: true
Location: InMemoryFileIndex [{warehouse_dir}/part]
PushedFilters: [IsNotNull(p_size), GreaterThanOrEqual(p_size,1), IsNotNull(p_partkey), Or(Or(And(And(EqualTo(p_brand,Brand#11),In(p_container, [SM BOX,SM CASE,SM PACK,SM PKG])),LessThanOrEqual(p_size,5)),And(And(EqualTo(p_brand,Brand#12),In(p_container, [MED BAG,MED BOX,MED PACK,MED PKG])),LessThanOrEqual(p_size,10))),And(And(EqualTo(p_brand,Brand#13),In(p_container, [LG BOX,LG CASE,LG PACK,LG PKG])),LessThanOrEqual(p_size,15)))]
PushedFilters: [IsNotNull(p_size), GreaterThanOrEqual(p_size,1), IsNotNull(p_partkey), Or(Or(And(And(EqualTo(p_brand,Brand#12),In(p_container, [SM BOX,SM CASE,SM PACK,SM PKG])),LessThanOrEqual(p_size,5)),And(And(EqualTo(p_brand,Brand#23),In(p_container, [MED BAG,MED BOX,MED PACK,MED PKG])),LessThanOrEqual(p_size,10))),And(And(EqualTo(p_brand,Brand#34),In(p_container, [LG BOX,LG CASE,LG PACK,LG PKG])),LessThanOrEqual(p_size,15)))]
ReadSchema: struct<p_partkey:bigint,p_brand:string,p_size:int,p_container:string>

(5) FilterExecTransformer
Input [4]: [p_partkey#7, p_brand#8, p_size#9, p_container#10]
Arguments: (((isnotnull(p_size#9) AND (p_size#9 >= 1)) AND isnotnull(p_partkey#7)) AND (((((p_brand#8 = Brand#11) AND p_container#10 IN (SM CASE,SM BOX,SM PACK,SM PKG)) AND (p_size#9 <= 5)) OR (((p_brand#8 = Brand#12) AND p_container#10 IN (MED BAG,MED BOX,MED PKG,MED PACK)) AND (p_size#9 <= 10))) OR (((p_brand#8 = Brand#13) AND p_container#10 IN (LG CASE,LG BOX,LG PACK,LG PKG)) AND (p_size#9 <= 15))))
Arguments: (((isnotnull(p_size#9) AND (p_size#9 >= 1)) AND isnotnull(p_partkey#7)) AND (((((p_brand#8 = Brand#12) AND p_container#10 IN (SM CASE,SM BOX,SM PACK,SM PKG)) AND (p_size#9 <= 5)) OR (((p_brand#8 = Brand#23) AND p_container#10 IN (MED BAG,MED BOX,MED PKG,MED PACK)) AND (p_size#9 <= 10))) OR (((p_brand#8 = Brand#34) AND p_container#10 IN (LG CASE,LG BOX,LG PACK,LG PKG)) AND (p_size#9 <= 15))))

(6) WholeStageCodegenTransformer (1)
Input [4]: [p_partkey#7, p_brand#8, p_size#9, p_container#10]
Expand All @@ -60,48 +60,48 @@ Input [4]: [p_partkey#7, p_brand#8, p_size#9, p_container#10]
Left keys [1]: [l_partkey#1]
Right keys [1]: [p_partkey#7]
Join type: Inner
Join condition: (((((((p_brand#8 = Brand#11) AND p_container#10 IN (SM CASE,SM BOX,SM PACK,SM PKG)) AND (l_quantity#2 >= 1)) AND (l_quantity#2 <= 11)) AND (p_size#9 <= 5)) OR (((((p_brand#8 = Brand#12) AND p_container#10 IN (MED BAG,MED BOX,MED PKG,MED PACK)) AND (l_quantity#2 >= 10)) AND (l_quantity#2 <= 20)) AND (p_size#9 <= 10))) OR (((((p_brand#8 = Brand#13) AND p_container#10 IN (LG CASE,LG BOX,LG PACK,LG PKG)) AND (l_quantity#2 >= 20)) AND (l_quantity#2 <= 30)) AND (p_size#9 <= 15)))
Join condition: (((((((p_brand#8 = Brand#12) AND p_container#10 IN (SM CASE,SM BOX,SM PACK,SM PKG)) AND (l_quantity#2 >= 1)) AND (l_quantity#2 <= 11)) AND (p_size#9 <= 5)) OR (((((p_brand#8 = Brand#23) AND p_container#10 IN (MED BAG,MED BOX,MED PKG,MED PACK)) AND (l_quantity#2 >= 10)) AND (l_quantity#2 <= 20)) AND (p_size#9 <= 10))) OR (((((p_brand#8 = Brand#34) AND p_container#10 IN (LG CASE,LG BOX,LG PACK,LG PKG)) AND (l_quantity#2 >= 20)) AND (l_quantity#2 <= 30)) AND (p_size#9 <= 15)))

(11) ProjectExecTransformer
Output [1]: [(l_extendedprice#3 * (1 - l_discount#4)) AS _pre_1#14]
Output [1]: [(l_extendedprice#3 * (1 - l_discount#4)) AS _pre_1#11]
Input [8]: [l_partkey#1, l_quantity#2, l_extendedprice#3, l_discount#4, p_partkey#7, p_brand#8, p_size#9, p_container#10]

(12) FlushableHashAggregateExecTransformer
Input [1]: [_pre_1#14]
Input [1]: [_pre_1#11]
Keys: []
Functions [1]: [partial_sum(_pre_1#14)]
Aggregate Attributes [2]: [sum#15, isEmpty#16]
Results [2]: [sum#17, isEmpty#18]
Functions [1]: [partial_sum(_pre_1#11)]
Aggregate Attributes [2]: [sum#12, isEmpty#13]
Results [2]: [sum#14, isEmpty#15]

(13) WholeStageCodegenTransformer (2)
Input [2]: [sum#17, isEmpty#18]
Input [2]: [sum#14, isEmpty#15]
Arguments: false

(14) VeloxResizeBatches
Input [2]: [sum#17, isEmpty#18]
Input [2]: [sum#14, isEmpty#15]
Arguments: 1024, 2147483647, 10485760

(15) ColumnarExchange
Input [2]: [sum#17, isEmpty#18]
Input [2]: [sum#14, isEmpty#15]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [plan_id=2], [shuffle_writer_type=hash]

(16) InputAdapter
Input [2]: [sum#17, isEmpty#18]
Input [2]: [sum#14, isEmpty#15]

(17) InputIteratorTransformer
Input [2]: [sum#17, isEmpty#18]
Input [2]: [sum#14, isEmpty#15]

(18) RegularHashAggregateExecTransformer
Input [2]: [sum#17, isEmpty#18]
Input [2]: [sum#14, isEmpty#15]
Keys: []
Functions [1]: [sum((l_extendedprice#3 * (1 - l_discount#4)))]
Aggregate Attributes [1]: [sum((l_extendedprice#3 * (1 - l_discount#4)))#19]
Results [1]: [sum((l_extendedprice#3 * (1 - l_discount#4)))#19 AS revenue#20]
Aggregate Attributes [1]: [sum((l_extendedprice#3 * (1 - l_discount#4)))#16]
Results [1]: [sum((l_extendedprice#3 * (1 - l_discount#4)))#16 AS revenue#17]

(19) WholeStageCodegenTransformer (3)
Input [1]: [revenue#20]
Input [1]: [revenue#17]
Arguments: false

(20) VeloxColumnarToRow
Input [1]: [revenue#20]
Input [1]: [revenue#17]

Loading
Loading