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 6ca9ec7be95 [hotfix][build] Fixes error message when printing the 15
biggest directories
add 042a4d2d8a8 [FLINK-21949][table] Support ARRAY_AGG aggregate function
(#23411)
No new revisions were added by this update.
Summary of changes:
docs/data/sql_functions.yml | 7 +
docs/data/sql_functions_zh.yml | 6 +
.../docs/reference/pyflink.table/expressions.rst | 1 +
flink-python/pyflink/table/expression.py | 4 +
.../pyflink/table/tests/test_expression.py | 1 +
.../src/main/codegen/data/Parser.tdd | 1 +
.../flink/sql/parser/FlinkSqlParserImplTest.java | 21 +-
.../flink/table/api/internal/BaseExpressions.java | 6 +
.../functions/BuiltInFunctionDefinitions.java | 7 +
.../planner/expressions/SqlAggFunctionVisitor.java | 2 +
.../functions/sql/FlinkSqlOperatorTable.java | 20 +
.../planner/plan/utils/AggFunctionFactory.scala | 9 +
.../table/planner/plan/utils/AggregateUtil.scala | 2 +-
.../planner/functions/ArrayAggFunctionITCase.java | 91 +++++
.../aggfunctions/ArrayAggFunctionTest.java | 411 +++++++++++++++++++++
.../functions/aggregate/ArrayAggFunction.java | 175 +++++++++
16 files changed, 758 insertions(+), 6 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/ArrayAggFunctionITCase.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/aggfunctions/ArrayAggFunctionTest.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/ArrayAggFunction.java
