You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2021/10/27 17:21:51 UTC
[flink] branch master updated (f6cfc07 -> 8106e27)

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 f6cfc07  [FLINK-24486][rest] Make async result store duration configurable
     add 99917be  [FLINK-16205][table-planner] Test base for aggregation functions
     add 2168e1f  [FLINK-16205][table-planner] Serialize JSON with stable key order
     add 8106e27  [FLINK-16205][table] Support JSON_OBJECTAGG

No new revisions were added by this update.

Summary of changes:
 docs/data/sql_functions.yml                        |  19 ++
 docs/data/sql_functions_zh.yml                     |  19 ++
 flink-python/pyflink/table/expressions.py          |  25 +-
 .../org/apache/flink/table/api/Expressions.java    |  38 +++
 .../table/api/ImplicitExpressionConversions.scala  |  23 ++
 .../functions/BuiltInFunctionDefinitions.java      |  20 ++
 .../planner/expressions/SqlAggFunctionVisitor.java |   6 +
 .../aggfunctions/JsonObjectAggFunction.java        | 188 ++++++++++++
 .../functions/bridging/BridgingSqlFunction.java    |   7 +
 .../functions/sql/FlinkSqlOperatorTable.java       |   5 +
 .../table/planner/hint/FlinkHintStrategies.java    |   7 +
 .../flink/table/planner/hint/FlinkHints.java       |   8 +
 .../logical/WrapJsonAggFunctionArgumentsRule.java  | 187 ++++++++++++
 .../planner/plan/rules/FlinkBatchRuleSets.scala    |   4 +-
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   4 +-
 .../planner/plan/utils/AggFunctionFactory.scala    |   7 +-
 .../BuiltInAggregateFunctionTestBase.java          | 330 +++++++++++++++++++++
 .../functions/JsonAggregationFunctionsITCase.java  | 123 ++++++++
 .../planner/functions/JsonFunctionsITCase.java     |  96 +++---
 ...a => WrapJsonAggFunctionArgumentsRuleTest.java} |  58 ++--
 ...ml => WrapJsonAggFunctionArgumentsRuleTest.xml} |  38 +--
 .../table/runtime/functions/SqlJsonUtils.java      |  11 +-
 22 files changed, 1110 insertions(+), 113 deletions(-)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/JsonObjectAggFunction.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/WrapJsonAggFunctionArgumentsRule.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInAggregateFunctionTestBase.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/JsonAggregationFunctionsITCase.java
 copy flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/logical/{RemoveUnreachableCoalesceArgumentsRuleTest.java => WrapJsonAggFunctionArgumentsRuleTest.java} (62%)
 copy flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/{FlinkPruneEmptyRulesTest.xml => WrapJsonAggFunctionArgumentsRuleTest.xml} (53%)