This is an automated email from the ASF dual-hosted git repository.
jingzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 259c7a4776a [FLINK-30429][client] Fix IllegalArgumentException when no
argument in flink executable
add 4c0f5e63775 [FLINK-29718][table] Supports hive sum function by native
implementation
No new revisions were added by this update.
Summary of changes:
.../hive/HiveDeclarativeAggregateFunction.java | 83 ++++++++++++++
.../table/functions/hive/HiveSumAggFunction.java | 127 +++++++++------------
.../apache/flink/table/module/hive/HiveModule.java | 7 ++
.../connectors/hive/HiveDialectQueryITCase.java | 85 ++++++++++++++
.../resources/explain/testSumAggFunctionPlan.out | 17 +++
.../expressions/UnresolvedReferenceExpression.java | 3 +-
.../functions}/DeclarativeAggregateFunction.java | 10 +-
.../functions/BuiltInFunctionDefinitions.java | 19 +++
...gy.java => HiveAggDecimalPlusTypeStrategy.java} | 17 ++-
.../strategies/SpecificTypeStrategies.java | 3 +
.../expressions/DeclarativeExpressionResolver.java | 2 +-
.../planner/expressions/ExpressionBuilder.java | 17 +++
.../functions/aggfunctions/AvgAggFunction.java | 1 +
.../functions/aggfunctions/Count1AggFunction.java | 1 +
.../functions/aggfunctions/CountAggFunction.java | 1 +
.../aggfunctions/CumeDistAggFunction.java | 1 +
.../functions/aggfunctions/LeadLagAggFunction.java | 1 +
.../functions/aggfunctions/ListAggFunction.java | 1 +
.../functions/aggfunctions/MaxAggFunction.java | 1 +
.../functions/aggfunctions/MinAggFunction.java | 1 +
.../functions/aggfunctions/NTILEAggFunction.java | 1 +
.../aggfunctions/RankLikeAggFunctionBase.java | 1 +
.../aggfunctions/RowNumberAggFunction.java | 1 +
.../aggfunctions/SingleValueAggFunction.java | 1 +
.../aggfunctions/SizeBasedWindowFunction.java | 1 +
.../functions/aggfunctions/Sum0AggFunction.java | 1 +
.../functions/aggfunctions/SumAggFunction.java | 1 +
.../aggfunctions/SumWithRetractAggFunction.java | 1 +
.../table/planner/codegen/ExprCodeGenerator.scala | 3 +-
.../codegen/agg/AggsHandlerCodeGenerator.scala | 3 +-
.../codegen/agg/DeclarativeAggCodeGen.scala | 3 +-
.../codegen/agg/batch/AggCodeGenHelper.scala | 3 +-
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 3 +-
.../codegen/agg/batch/HashAggCodeGenerator.scala | 3 +-
.../physical/batch/BatchPhysicalAggRuleBase.scala | 3 +-
.../batch/BatchPhysicalWindowAggregateRule.scala | 3 +-
.../planner/plan/utils/AggFunctionFactory.scala | 5 +-
.../table/planner/plan/utils/AggregateUtil.scala | 72 +++++++-----
.../table/planner/plan/utils/PythonUtil.scala | 9 +-
.../table/planner/plan/utils/RelExplainUtil.scala | 3 +-
40 files changed, 371 insertions(+), 148 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveDeclarativeAggregateFunction.java
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/SumAggFunction.java
=>
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSumAggFunction.java
(50%)
create mode 100644
flink-connectors/flink-connector-hive/src/test/resources/explain/testSumAggFunctionPlan.out
rename
flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions
=>
flink-table-api-java/src/main/java/org/apache/flink/table/functions}/DeclarativeAggregateFunction.java
(96%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{AggDecimalPlusTypeStrategy.java
=> HiveAggDecimalPlusTypeStrategy.java} (77%)
