You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ro...@apache.org on 2023/07/05 15:20:51 UTC

[pinot] branch master updated (f7a076496a -> 6c8eb96dd8)

This is an automated email from the ASF dual-hosted git repository.

rongr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git


    from f7a076496a Startree index build enhancement (#10905)
     add 6c8eb96dd8 [multistage] Initial planner changes to support the v1 aggregation functions in multistage (#10846)

No new revisions were added by this update.

Summary of changes:
 .../pinot-segment-spi-jdk8/pom.xml                 |   4 +
 .../function/AggregationFunctionFactory.java       |   8 +-
 .../reduce/function/InternalReduceFunctions.java   |  21 +-
 .../calcite/rel/hint/PinotHintStrategyTable.java   |  23 +-
 .../PinotAggregateExchangeNodeInsertRule.java      | 280 ++++++++++----
 .../rules/PinotAggregateReduceFunctionsRule.java   | 427 +++++++++++++++++++++
 .../calcite/rel/rules/PinotQueryRuleSets.java      |   3 +-
 .../rules/PinotReduceAggregateFunctionsRule.java   | 234 -----------
 .../apache/calcite/sql/PinotSqlAggFunction.java    |  47 +++
 .../sql/fun/PinotBoolAndAggregateFunction.java     |  39 --
 .../sql/fun/PinotBoolOrAggregateFunction.java      |  39 --
 .../fun/PinotDistinctCountAggregateFunction.java   |  40 --
 .../fun/PinotFourthMomentAggregateFunction.java    |  40 --
 .../sql/fun/PinotKurtosisAggregateFunction.java    |  40 --
 .../apache/calcite/sql/fun/PinotOperatorTable.java | 162 +++++++-
 .../sql/fun/PinotSkewnessAggregateFunction.java    |  40 --
 .../planner/physical/DispatchablePlanVisitor.java  |   2 +-
 .../query/planner/plannode/AggregateNode.java      |  78 +++-
 .../apache/pinot/query/QueryCompilationTest.java   |   1 +
 .../pinot/query/QueryEnvironmentTestBase.java      |  19 +
 .../src/test/resources/queries/AggregatePlans.json | 203 ++++++++--
 .../test/resources/queries/BasicQueryPlans.json    |   8 +-
 .../src/test/resources/queries/GroupByPlans.json   | 322 +++++++++++-----
 .../src/test/resources/queries/JoinPlans.json      | 101 ++---
 .../src/test/resources/queries/OrderByPlans.json   |  36 +-
 .../test/resources/queries/PinotHintablePlans.json | 101 +++--
 .../resources/queries/WindowFunctionPlans.json     | 264 ++++++++-----
 .../query/runtime/operator/AggregateOperator.java  | 324 +++++++---------
 .../operator/MultistageAggregationExecutor.java    |  16 +-
 .../operator/MultistageGroupByExecutor.java        |  16 +-
 .../runtime/operator/NewAggregateOperator.java     | 295 --------------
 .../query/runtime/plan/PhysicalPlanVisitor.java    |  19 +-
 .../runtime/operator/AggregateOperatorTest.java    |  66 +---
 .../src/test/resources/queries/QueryHints.json     |   4 +
 pinot-segment-spi/pom.xml                          |   4 +
 .../pinot/segment/spi/AggregationFunctionType.java | 175 ++++++++-
 36 files changed, 2009 insertions(+), 1492 deletions(-)
 create mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/rel/rules/PinotAggregateReduceFunctionsRule.java
 delete mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/rel/rules/PinotReduceAggregateFunctionsRule.java
 create mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/sql/PinotSqlAggFunction.java
 delete mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/sql/fun/PinotBoolAndAggregateFunction.java
 delete mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/sql/fun/PinotBoolOrAggregateFunction.java
 delete mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/sql/fun/PinotDistinctCountAggregateFunction.java
 delete mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/sql/fun/PinotFourthMomentAggregateFunction.java
 delete mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/sql/fun/PinotKurtosisAggregateFunction.java
 delete mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/sql/fun/PinotSkewnessAggregateFunction.java
 delete mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/NewAggregateOperator.java


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org