This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 062ab75c3ff [hotfix][python] Update the incomplete cloudpickle package
add 1957ef5fabe [FLINK-31118][table] Add ARRAY_UNION function. (#22483)
No new revisions were added by this update.
Summary of changes:
docs/data/sql_functions.yml | 155 +++++++++++----------
.../docs/reference/pyflink.table/expressions.rst | 1 +
flink-python/pyflink/table/expression.py | 7 +
.../flink/table/api/internal/BaseExpressions.java | 11 ++
.../functions/BuiltInFunctionDefinitions.java | 11 ++
.../table/types/inference/InputTypeStrategies.java | 9 ++
...tegy.java => CommonArrayInputTypeStrategy.java} | 14 +-
.../CommonArrayInputTypeStrategyTest.java | 55 ++++++++
.../functions/CollectionFunctionsITCase.java | 66 ++++++++-
...stinctFunction.java => ArrayUnionFunction.java} | 76 ++++++----
10 files changed, 295 insertions(+), 110 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{CommonInputTypeStrategy.java
=> CommonArrayInputTypeStrategy.java} (87%)
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/CommonArrayInputTypeStrategyTest.java
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/{ArrayDistinctFunction.java
=> ArrayUnionFunction.java} (62%)
