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/08/12 10:07:40 UTC

[flink] branch master updated (bc5890e -> db2e333)

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 bc5890e  [FLINK-11634][docs] Translate "State Backends" page into Chinese (#16522)
     add 6e75c88  [hotfix][table-planner] Propagate AssertionError in BuiltInFunctionTestBase
     add 7439b69  [hotfix][table-common] Introduce a symbol() argument type strategy
     add a901173  [hotfix][table-planner] Allow BuiltInFunctionTestBase to assert on runtime errors
     add 334082d  [FLINK-16200][table] Support JSON_EXISTS in SQL & Table API
     add db2e333  [FLINK-16200][table-planner] Refactor CustomizedConvertRule

No new revisions were added by this update.

Summary of changes:
 .../docs/dev/table/functions/systemFunctions.md    |  21 ++
 .../docs/dev/table/functions/systemFunctions.md    |  21 ++
 docs/data/sql_functions.yml                        |  25 ++
 docs/data/sql_functions_zh.yml                     |  25 ++
 flink-python/pyflink/table/expression.py           |  41 +-
 .../flink/table/api/internal/BaseExpressions.java  |  62 +++
 .../apache/flink/table/api/JsonExistsOnError.java  |  32 ++
 .../table/functions/BuiltInFunctionDefinition.java |  15 +
 .../functions/BuiltInFunctionDefinitions.java      |  27 ++
 .../table/types/inference/InputTypeStrategies.java |   8 +
 .../strategies/SymbolArgumentTypeStrategy.java     |  99 +++++
 .../flink/table/types/logical/SymbolType.java      |   4 +
 .../strategies/SymbolArgumentTypeStrategyTest.java |  74 ++++
 .../converter/CallExpressionConvertRule.java       |   2 +
 .../converter/CustomizedConvertRule.java           | 414 +--------------------
 .../expressions/converter/DirectConvertRule.java   |   2 +
 .../converter/converters/ArrayConverter.java       |  48 +++
 .../converter/converters/AsConverter.java          |  40 ++
 .../converter/converters/BetweenConverter.java     |  51 +++
 .../converter/converters/CastConverter.java        |  44 +++
 .../converter/converters/CustomizedConverter.java  |  55 +++
 .../converter/converters/CustomizedConverters.java |  62 +++
 .../converter/converters/GetConverter.java         |  46 +++
 .../converter/converters/InConverter.java          |  59 +++
 .../converter/converters/JsonExistsConverter.java  |  59 +++
 .../converter/converters/MapConverter.java         |  48 +++
 .../converter/converters/NotBetweenConverter.java  |  48 +++
 .../converter/converters/OrderAscConverter.java    |  34 ++
 .../converter/converters/PlusConverter.java        |  75 ++++
 .../converters/ReinterpretCastConverter.java       |  47 +++
 .../converter/converters/ReplaceConverter.java     |  54 +++
 .../converter/converters/RowConverter.java         |  45 +++
 .../converter/converters/SqrtConverter.java        |  47 +++
 .../converters/TemporalOverlapsConverter.java      |  92 +++++
 .../converters/ThrowExceptionConverter.java        |  44 +++
 .../converters/TimestampDiffConverter.java         |  46 +++
 .../converter/converters/TrimConverter.java        |  64 ++++
 .../functions/sql/FlinkSqlOperatorTable.java       |   1 +
 .../planner/codegen/calls/BuiltInMethods.scala     |  14 +-
 .../planner/codegen/calls/FunctionGenerator.scala  |   5 +
 .../planner/functions/BuiltInFunctionTestBase.java |  68 +++-
 .../functions/GreatestLeastFunctionsITCase.java    |   6 +-
 .../functions/JsonExistsFunctionITCase.java        | 129 +++++++
 .../planner/functions/MiscFunctionsITCase.java     |   8 +-
 .../src/test/resources/json/json-exists.json       |  19 +
 pom.xml                                            |   1 +
 tools/maven/suppressions.xml                       |   2 +-
 47 files changed, 1801 insertions(+), 432 deletions(-)
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/JsonExistsOnError.java
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SymbolArgumentTypeStrategy.java
 create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/SymbolArgumentTypeStrategyTest.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/ArrayConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/AsConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/BetweenConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/CastConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/CustomizedConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/CustomizedConverters.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/GetConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/InConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/JsonExistsConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/MapConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/NotBetweenConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/OrderAscConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/PlusConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/ReinterpretCastConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/ReplaceConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/RowConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/SqrtConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/TemporalOverlapsConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/ThrowExceptionConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/TimestampDiffConverter.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/TrimConverter.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/JsonExistsFunctionITCase.java
 create mode 100644 flink-table/flink-table-planner/src/test/resources/json/json-exists.json