jinchengchenghh commented on PR #6036:
URL:
https://github.com/apache/incubator-gluten/pull/6036#issuecomment-2185510139
This test cannot test if the function is used.
Because `knownnullable` is not supported, so the function fallback, it just
check `(8) ProjectExecTransformer [a#143, window#169.start AS start#170,
window#169.end AS end#171, count(1)#168L AS cnt#167L]`
The plan is
```
VeloxColumnarToRowExec
+- ^(9) SortExecTransformer [a#143 ASC NULLS FIRST, start#170 ASC NULLS
FIRST], true, 0
+- ^(9) InputIteratorTransformer[a#143, start#170, end#171, cnt#167L]
+- ShuffleQueryStage 1
+- ColumnarExchange rangepartitioning(a#143 ASC NULLS FIRST,
start#170 ASC NULLS FIRST, 1), ENSURE_REQUIREMENTS, [plan_id=633], [id=#633],
[OUTPUT] List(a:StringType, start:TimestampType, end:TimestampType,
cnt:LongType), [OUTPUT] List(a:StringType, start:TimestampType,
end:TimestampType, cnt:LongType)
+- ^(8) ProjectExecTransformer [a#143, window#169.start AS
start#170, window#169.end AS end#171, count(1)#168L AS cnt#167L]
+- ^(8) HashAggregateTransformer(keys=[a#143, window#169],
functions=[count(1)], output=[a#143, window#169, count(1)#168L])
+- ^(8) InputIteratorTransformer[a#143, window#169,
count#179L]
+- RowToVeloxColumnar
+- ShuffleQueryStage 0
+- Exchange hashpartitioning(a#143,
window#169, 1), ENSURE_REQUIREMENTS, [plan_id=567]
+- VeloxColumnarToRowExec
+- ^(7)
FlushableHashAggregateTransformer(keys=[a#143, window#169],
functions=[partial_count(1)], output=[a#143, window#169, count#179L])
+- ^(7)
InputIteratorTransformer[window#169, a#143]
+- RowToVeloxColumnar
+- *(2) Project
[named_struct(start,
knownnullable(precisetimestampconversion(((precisetimestampconversion(b#144,
TimestampType, LongType) - CASE WHEN (((precisetimestampconversion(b#144,
TimestampType, LongType) - 0) % 300000000) < cast(0 as bigint)) THEN
(((precisetimestampconversion(b#144, TimestampType, LongType) - 0) % 300000000)
+ 300000000) ELSE ((precisetimestampconversion(b#144, TimestampType, LongType)
- 0) % 300000000) END) - 0), LongType, TimestampType)), end,
knownnullable(precisetimestampconversion((((precisetimestampconversion(b#144,
TimestampType, LongType) - CASE WHEN (((precisetimestampconversion(b#144,
TimestampType, LongType) - 0) % 300000000) < cast(0 as bigint)) THEN
(((precisetimestampconversion(b#144, TimestampType, LongType) - 0) % 300000000)
+ 300000000) ELSE ((precisetimestampconversion(b#144, TimestampType, LongType)
- 0) % 300000000) END) - 0) + 300000000), LongType, TimestampType))) AS
window#169, a#143]
+- VeloxColumnarToRowExec
+- ^(6)
FilterExecTransformer isnotnull(b#144)
+- ^(6)
InputIteratorTransformer[a#143, b#144]
+-
RowToVeloxColumnar
+- *(1)
ColumnarToRow
+- BatchScan
parquet file:/tmp/spark-3ebf1be6-44e8-4f33-a661-3540f556
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
