You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2023/07/03 15:19:39 UTC
[flink] branch master updated (aad2023b379 -> 962e51f7718)
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 aad2023b379 [hotfix] Add missing release note on binding to localhost by default since Flink 1.15
add 962e51f7718 [FLINK-32259]-table-Add-ARRAY_JOIN-function
No new revisions were added by this update.
Summary of changes:
docs/data/sql_functions.yml | 3 +
.../docs/reference/pyflink.table/expressions.rst | 1 +
flink-python/pyflink/table/expression.py | 14 +
.../functions/BuiltInFunctionDefinitions.java | 19 ++
...java => ArrayOfStringArgumentTypeStrategy.java} | 69 ++---
.../functions/CollectionFunctionsITCase.java | 311 ++++++++++++++++++++-
.../functions/scalar/ArrayJoinFunction.java | 112 ++++++++
7 files changed, 489 insertions(+), 40 deletions(-)
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{ConstraintArgumentTypeStrategy.java => ArrayOfStringArgumentTypeStrategy.java} (52%)
create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayJoinFunction.java