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 b3dea50 [FLINK-23247][table-planner] Materialize time attribute
fields of regular join's inputs
add 6e977ea [hotfix][table-planner] Extend BuiltInFunctionTestBase to
expect different data types
add 2b053ec [hotfix][table-common] Introduce a strategy for type literal
arguments
add 59c8f61 [hotfix][table-common] Introduce forceNullable as a type
strategy
add b5a30e0 [FLINK-16201][table] Support JSON_VALUE
add a45efb8 [hotfix][python] Remove jsonExists and jsonValue from PyFlink
for now
add 3804cd3 [hotfix][table-common] Rename nullable() to nullableIfArgs()
No new revisions were added by this update.
Summary of changes:
docs/data/sql_functions.yml | 37 ++++
docs/data/sql_functions_zh.yml | 37 ++++
flink-python/pyflink/table/expression.py | 42 +---
.../table/tests/test_expression_completeness.py | 4 +
.../flink/table/api/internal/BaseExpressions.java | 139 ++++++++++++
...tsOnError.java => JsonValueOnEmptyOrError.java} | 14 +-
.../functions/BuiltInFunctionDefinitions.java | 178 +++++++++-------
.../table/types/inference/InputTypeStrategies.java | 5 +
.../table/types/inference/TypeStrategies.java | 16 +-
...trategy.java => ForceNullableTypeStrategy.java} | 18 +-
...rategy.java => NullableIfArgsTypeStrategy.java} | 6 +-
...y.java => TypeLiteralArgumentTypeStrategy.java} | 19 +-
.../table/types/inference/TypeStrategiesTest.java | 12 +-
.../TypeLiteralArgumentTypeStrategyTest.java | 50 +++++
.../converter/converters/CustomizedConverters.java | 1 +
.../converter/converters/JsonValueConverter.java | 111 ++++++++++
.../functions/sql/FlinkSqlOperatorTable.java | 1 +
.../table/planner/codegen/ExprCodeGenerator.scala | 2 +
.../planner/codegen/calls/BuiltInMethods.scala | 11 +-
.../planner/codegen/calls/FunctionGenerator.scala | 24 +--
.../planner/codegen/calls/JsonValueCallGen.scala | 101 +++++++++
.../planner/functions/BuiltInFunctionTestBase.java | 13 +-
.../functions/JsonExistsFunctionITCase.java | 129 ------------
.../planner/functions/JsonFunctionsITCase.java | 233 +++++++++++++++++++++
.../src/test/resources/json/json-value.json | 10 +
25 files changed, 906 insertions(+), 307 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/{JsonExistsOnError.java
=> JsonValueOnEmptyOrError.java} (78%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{MissingTypeStrategy.java
=> ForceNullableTypeStrategy.java} (77%)
rename
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{NullableTypeStrategy.java
=> NullableIfArgsTypeStrategy.java} (95%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{CompositeArgumentTypeStrategy.java
=> TypeLiteralArgumentTypeStrategy.java} (71%)
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/TypeLiteralArgumentTypeStrategyTest.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/JsonValueConverter.java
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/JsonValueCallGen.scala
delete 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/java/org/apache/flink/table/planner/functions/JsonFunctionsITCase.java
create mode 100644
flink-table/flink-table-planner/src/test/resources/json/json-value.json
