This is an automated email from the ASF dual-hosted git repository.
jayzhan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 1d3bdbe14f Minor: add ticket reference and fmt (#11805)
1d3bdbe14f is described below
commit 1d3bdbe14fd01bbd03abeb57d3ec9bc155a36d71
Author: Andrew Lamb <[email protected]>
AuthorDate: Sun Aug 4 20:16:36 2024 -0400
Minor: add ticket reference and fmt (#11805)
---
datafusion/proto/src/physical_plan/mod.rs | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git a/datafusion/proto/src/physical_plan/mod.rs
b/datafusion/proto/src/physical_plan/mod.rs
index fbb9e44298..aefa1d87a2 100644
--- a/datafusion/proto/src/physical_plan/mod.rs
+++ b/datafusion/proto/src/physical_plan/mod.rs
@@ -489,7 +489,13 @@ impl AsExecutionPlan for protobuf::PhysicalPlanNode {
// TODO: approx_percentile_cont
and approx_percentile_cont_weight are not supported for UDAF from protobuf yet.
// TODO: `order by` is not
supported for UDAF yet
- AggregateExprBuilder::new(agg_udf,
input_phy_expr).schema(Arc::clone(&physical_schema)).name(name).with_ignore_nulls(agg_node.ignore_nulls).with_distinct(agg_node.distinct).build()
+ //
https://github.com/apache/datafusion/issues/11804
+ AggregateExprBuilder::new(agg_udf,
input_phy_expr)
+
.schema(Arc::clone(&physical_schema))
+ .name(name)
+
.with_ignore_nulls(agg_node.ignore_nulls)
+
.with_distinct(agg_node.distinct)
+ .build()
}
}
}).transpose()?.ok_or_else(|| {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
