This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 2ca7e411f53 [hotfix] Remove legacy code which was not removed due
merge conflicts
add ec3243e36ee [FLINK-27920][hive] Supports native avg function for hive
dialect
No new revisions were added by this update.
Summary of changes:
.../functions/hive/HiveAverageAggFunction.java | 213 +++++++++++++++++++++
.../hive/HiveDeclarativeAggregateFunction.java | 16 ++
.../table/functions/hive/HiveSumAggFunction.java | 21 +-
.../apache/flink/table/module/hive/HiveModule.java | 15 +-
.../connectors/hive/HiveDialectAggITCase.java | 64 +++++++
.../connectors/hive/HiveDialectQueryPlanTest.java | 14 ++
...Plan.out => testAvgAggFunctionFallbackPlan.out} | 10 +-
...FunctionPlan.out => testAvgAggFunctionPlan.out} | 10 +-
8 files changed, 334 insertions(+), 29 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveAverageAggFunction.java
copy
flink-connectors/flink-connector-hive/src/test/resources/explain/{testMinAggFunctionFallbackPlan.out
=> testAvgAggFunctionFallbackPlan.out} (69%)
copy
flink-connectors/flink-connector-hive/src/test/resources/explain/{testMaxAggFunctionPlan.out
=> testAvgAggFunctionPlan.out} (53%)
