This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b608620 [FLINK-23969][connector/pulsar] Create e2e tests for pulsar
connector.
add 4090a06 [hotfix] Proxy SplitContext#isArgumentNull correctly
add cd08b4b [hotfix] Relax condition for argument count
add f0be546 [hotfix] Introduce InputTypeStrategies#repeatingSequence
add 463a7d4 [hotfix] Remove unused JsonUtils
add 7a6bca8 [hotfix] Make all converters @Internal
add 0fb8db5 [hotfix] remove duplicate case
add b30fdef [hotfix] Handle ANY during type inference
add c643241 [FLINK-16203][table] Support JSON_OBJECT
No new revisions were added by this update.
Summary of changes:
docs/data/sql_functions.yml | 33 ++
docs/data/sql_functions_zh.yml | 34 ++
flink-python/pyflink/table/expression.py | 14 +
flink-python/pyflink/table/expressions.py | 39 +-
.../org/apache/flink/table/api/Expressions.java | 37 ++
.../table/api/ImplicitExpressionConversions.scala | 31 ++
...sonQueryOnEmptyOrError.java => JsonOnNull.java} | 13 +-
.../functions/BuiltInFunctionDefinitions.java | 9 +
.../table/types/inference/InputTypeStrategies.java | 6 +
...ava => RepeatingSequenceInputTypeStrategy.java} | 92 ++--
.../strategies/SpecificInputTypeStrategies.java | 30 ++
.../strategies/SubsequenceInputTypeStrategy.java | 8 +-
.../RepeatingSequenceInputTypeStrategyTest.java | 64 +++
.../converter/converters/ArrayConverter.java | 2 +
.../converter/converters/AsConverter.java | 2 +
.../converter/converters/BetweenConverter.java | 2 +
.../converter/converters/CastConverter.java | 2 +
.../converter/converters/CustomizedConverters.java | 1 +
.../converter/converters/GetConverter.java | 2 +
.../converter/converters/InConverter.java | 2 +
.../converter/converters/IsJsonConverter.java | 2 +
.../converter/converters/JsonExistsConverter.java | 2 +
.../converter/converters/JsonObjectConverter.java | 77 ++++
.../converter/converters/JsonQueryConverter.java | 2 +
.../converter/converters/JsonValueConverter.java | 2 +
.../converter/converters/MapConverter.java | 2 +
.../converter/converters/NotBetweenConverter.java | 2 +
.../converter/converters/OrderAscConverter.java | 2 +
.../converter/converters/PlusConverter.java | 2 +
.../converters/ReinterpretCastConverter.java | 2 +
.../converter/converters/ReplaceConverter.java | 2 +
.../converter/converters/RowConverter.java | 2 +
.../converter/converters/SqrtConverter.java | 2 +
.../converters/TemporalOverlapsConverter.java | 2 +
.../converters/ThrowExceptionConverter.java | 2 +
.../converters/TimestampDiffConverter.java | 2 +
.../converter/converters/TrimConverter.java | 2 +
.../inference/CallBindingCallContext.java | 5 +-
.../functions/sql/FlinkSqlOperatorTable.java | 1 +
.../functions/sql/SqlJsonObjectFunction.java | 159 +++++++
.../flink/table/planner/codegen/CodeGenUtils.scala | 1 -
.../table/planner/codegen/ExprCodeGenerator.scala | 2 +
.../table/planner/codegen/ExpressionReducer.scala | 142 ++++---
.../table/planner/codegen/JsonGenerateUtils.scala | 237 +++++++++++
.../planner/codegen/calls/BuiltInMethods.scala | 7 +-
.../planner/codegen/calls/JsonObjectCallGen.scala | 107 +++++
.../planner/codegen/calls/StringCallGen.scala | 1 -
.../planner/functions/JsonFunctionsITCase.java | 360 +++++++++++-----
.../table/runtime/functions/SqlFunctionUtils.java | 6 -
.../table/runtime/functions/SqlJsonUtils.java | 52 +--
.../apache/flink/table/runtime/util/JsonUtils.java | 470 ---------------------
51 files changed, 1352 insertions(+), 730 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/{JsonQueryOnEmptyOrError.java
=> JsonOnNull.java} (80%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{SequenceInputTypeStrategy.java
=> RepeatingSequenceInputTypeStrategy.java} (55%)
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/RepeatingSequenceInputTypeStrategyTest.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/converters/JsonObjectConverter.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/SqlJsonObjectFunction.java
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/JsonGenerateUtils.scala
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/JsonObjectCallGen.scala
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/SerializedValueDeserializer.java
=>
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/SqlJsonUtils.java
(52%)
delete mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/util/JsonUtils.java
