This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 62b20b0 [FLINK-18878][python] Support dependency management for
Python StreamExecutionEnvironment. (#13136)
add dc73dbf [FLINK-18901][table] Use new type inference for aggregate
functions in SQL DDL
No new revisions were added by this update.
Summary of changes:
.../factories/HiveFunctionDefinitionFactory.java | 13 +-
.../flink/table/catalog/FunctionCatalog.java | 15 +-
.../table/functions/FunctionDefinitionUtil.java | 93 ----------
.../flink/table/catalog/FunctionCatalogTest.java | 8 +-
.../functions/FunctionDefinitionUtilTest.java | 195 ---------------------
.../api/bridge/scala/StreamTableEnvironment.scala | 21 +++
.../table/functions/UserDefinedFunctionHelper.java | 41 ++++-
.../functions/UserDefinedFunctionHelperTest.java | 97 +++++++++-
.../planner/runtime/stream/sql/FunctionITCase.java | 66 +++++++
9 files changed, 233 insertions(+), 316 deletions(-)
delete mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/functions/FunctionDefinitionUtil.java
delete mode 100644
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/functions/FunctionDefinitionUtilTest.java
