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