[flink] branch master updated (259c7a4776a -> 4c0f5e63775)

[ji...@apache.org]

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%)