This is an automated email from the ASF dual-hosted git repository.
ulyssesyou pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new f9bd49006 [VL] Add isStreamingAgg info to HashAggregateTransformer
(#6307)
f9bd49006 is described below
commit f9bd4900640dfd222065e9b6b22dd5a21be1bf7d
Author: Joey <[email protected]>
AuthorDate: Tue Jul 2 16:25:02 2024 +0800
[VL] Add isStreamingAgg info to HashAggregateTransformer (#6307)
---
.../gluten/execution/HashAggregateExecBaseTransformer.scala | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git
a/gluten-core/src/main/scala/org/apache/gluten/execution/HashAggregateExecBaseTransformer.scala
b/gluten-core/src/main/scala/org/apache/gluten/execution/HashAggregateExecBaseTransformer.scala
index 49a9ee1e8..9345b3a36 100644
---
a/gluten-core/src/main/scala/org/apache/gluten/execution/HashAggregateExecBaseTransformer.scala
+++
b/gluten-core/src/main/scala/org/apache/gluten/execution/HashAggregateExecBaseTransformer.scala
@@ -84,9 +84,14 @@ abstract class HashAggregateExecBaseTransformer(
val functionString = truncatedString(allAggregateExpressions, "[", ", ",
"]", maxFields)
val outputString = truncatedString(output, "[", ", ", "]", maxFields)
if (verbose) {
- s"HashAggregateTransformer(keys=$keyString, functions=$functionString,
output=$outputString)"
+ s"HashAggregateTransformer(keys=$keyString, " +
+ s"functions=$functionString, " +
+ s"isStreamingAgg=$isCapableForStreamingAggregation, " +
+ s"output=$outputString)"
} else {
- s"HashAggregateTransformer(keys=$keyString, functions=$functionString)"
+ s"HashAggregateTransformer(keys=$keyString, " +
+ s"functions=$functionString, " +
+ s"isStreamingAgg=$isCapableForStreamingAggregation)"
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
