You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ja...@apache.org on 2022/07/06 08:47:25 UTC

[flink] branch master updated (342dfd16e57 -> bcd619f43da)

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

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


    from 342dfd16e57 [FLINK-26979][core][tests] Add thread-safety test
     add bcd619f43da [FLINK-15855][hive] Use the new type inference for Hive UDAF

No new revisions were added by this update.

Summary of changes:
 .../factories/HiveFunctionDefinitionFactory.java   | 23 ++----
 .../table/functions/hive/HiveGenericUDAF.java      | 68 ++++++++++------
 .../table/functions/hive/HiveLegacyFunction.java   | 54 ------------
 .../planner/delegation/hive/HiveParserUtils.java   | 95 +++++++++++++++++++---
 .../hive/copy/HiveParserBaseSemanticAnalyzer.java  |  4 +-
 .../table/functions/hive/HiveGenericUDAFTest.java  | 32 +++++---
 .../src/test/resources/query-test/udaf.q           |  9 ++
 .../catalog/FunctionCatalogOperatorTable.java      | 13 +--
 .../functions/utils/HiveAggSqlFunction.java        | 91 ---------------------
 .../planner/functions/utils/HiveFunctionUtils.java | 86 --------------------
 10 files changed, 166 insertions(+), 309 deletions(-)
 delete mode 100644 flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveLegacyFunction.java
 create mode 100644 flink-connectors/flink-connector-hive/src/test/resources/query-test/udaf.q
 delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/utils/HiveAggSqlFunction.java
 delete mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/utils/HiveFunctionUtils.java