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 9785ea4 [FLINK-23004][yarn] Fix misleading log
new 0764893 [hotfix][table-common][table-planner-blink] Support deferred
runtime implementation for built-in functions
new 8bd215d [FLINK-22737][table-common][table-planner-blink] Introduce
CURRENT_WATERMARK()
new 66aa018 [hotfix][docs] Allow formatting in SQL functions docs
new 5bae5b5 [hotfix][table-common] Move specific type strategies out of
TypeStrategies
new c60c036 [hotfix][table-common] Move specific input type strategies
out of InputTypeStrategies
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/data/sql_functions.yml | 14 +-
docs/layouts/shortcodes/sql_functions.html | 4 +-
flink-python/pyflink/table/expressions.py | 28 +-
.../org/apache/flink/table/api/Expressions.java | 21 ++
.../table/api/ImplicitExpressionConversions.scala | 20 ++
.../table/functions/BuiltInFunctionDefinition.java | 26 +-
.../functions/BuiltInFunctionDefinitions.java | 69 +++--
.../table/types/inference/InputTypeStrategies.java | 40 ---
.../table/types/inference/TypeStrategies.java | 337 --------------------
.../inference/strategies/ArrayTypeStrategy.java | 46 +++
.../strategies/CastInputTypeStrategy.java | 2 +-
...java => CurrentWatermarkInputTypeStrategy.java} | 59 ++--
.../strategies/CurrentWatermarkTypeStrategy.java | 53 ++++
.../strategies/DecimalDivideTypeStrategy.java | 73 +++++
.../strategies/DecimalModTypeStrategy.java | 76 +++++
.../strategies/DecimalPlusTypeStrategy.java | 72 +++++
.../strategies/DecimalScale0TypeStrategy.java | 62 ++++
.../strategies/DecimalTimesTypeStrategy.java | 73 +++++
.../inference/strategies/GetTypeStrategy.java | 64 ++++
.../inference/strategies/IfNullTypeStrategy.java | 44 +++
.../inference/strategies/MapInputTypeStrategy.java | 2 +-
.../inference/strategies/MapTypeStrategy.java | 47 +++
.../inference/strategies/RoundTypeStrategy.java | 79 +++++
.../inference/strategies/RowTypeStrategy.java | 45 +++
.../strategies/SourceWatermarkTypeStrategy.java | 45 +++
.../strategies/SpecificInputTypeStrategies.java | 78 +++++
.../strategies/SpecificTypeStrategies.java | 79 +++++
.../types/inference/strategies/StrategyUtils.java | 12 +
.../strategies/StringConcatTypeStrategy.java | 74 +++++
.../inference/ComparableInputTypeStrategyTest.java | 46 +--
.../types/inference/InputTypeStrategiesTest.java | 18 +-
.../inference/InputTypeStrategiesTestBase.java | 22 +-
.../types/inference/MappingTypeStrategiesTest.java | 75 +++++
.../table/types/inference/TypeStrategiesTest.java | 342 ++-------------------
.../types/inference/TypeStrategiesTestBase.java | 165 ++++++++++
.../strategies/ArrayTypeStrategyTest.java | 39 +++
.../CurrentWatermarkInputTypeStrategyTest.java | 79 +++++
.../CurrentWatermarkTypeStrategyTest.java | 69 +++++
.../strategies/DecimalTypeStrategyTest.java | 50 +++
.../inference/strategies/GetTypeStrategyTest.java | 137 +++++++++
.../inference/strategies/MapTypeStrategyTest.java | 41 +++
.../inference/strategies/RowTypeStrategyTest.java | 43 +++
.../strategies/StringConcatTypeStrategyTest.java | 39 +++
.../catalog/FunctionCatalogOperatorTable.java | 2 +-
.../converter/FunctionDefinitionConvertRule.java | 2 +-
.../table/planner/codegen/ExprCodeGenerator.scala | 6 +-
.../table/planner/codegen/GenerateUtils.scala | 20 ++
.../planner/runtime/stream/sql/CalcITCase.scala | 98 ++++++
48 files changed, 2129 insertions(+), 808 deletions(-)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayTypeStrategy.java
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{CastInputTypeStrategy.java
=> CurrentWatermarkInputTypeStrategy.java} (55%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CurrentWatermarkTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/DecimalDivideTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/DecimalModTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/DecimalPlusTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/DecimalScale0TypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/DecimalTimesTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/GetTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/IfNullTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MapTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RoundTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RowTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SourceWatermarkTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificTypeStrategies.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/StringConcatTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/MappingTypeStrategiesTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/TypeStrategiesTestBase.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/ArrayTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/CurrentWatermarkInputTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/CurrentWatermarkTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/DecimalTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/GetTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/MapTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/RowTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/StringConcatTypeStrategyTest.java
