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 e79dd4e [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and
BytesMultiMap to support window key
add e5bf1cb [FLINK-20522][table] Add SpecializedFunction for hooking into
the UDF generation
add 4796b3c [hotfix][table-common] Add
DataTypeUtils.toInternalDataType(DataType)
add bd3bb36 [FLINK-20522][table] Introduce built-in runtime functions
add 7fd1603 [FLINK-20522][table-planner-blink] Migrate
InternalAggregateFunction to BuiltInAggregateFunction
add a9da229 [hotfix][table-common] Reformat BuiltInFunctionDefinitions
add 857a5b9 [FLINK-20522][table] Add built-in TYPEOF function
add df46f89 [FLINK-20522][table] Add built-in IFNULL function
No new revisions were added by this update.
Summary of changes:
docs/dev/table/functions/systemFunctions.md | 101 ++++-
flink-python/pyflink/table/expression.py | 16 +
.../flink/table/api/internal/BaseExpressions.java | 123 +++++-
.../table/functions/BuiltInFunctionDefinition.java | 63 ++-
.../functions/BuiltInFunctionDefinitions.java | 464 +++++++++++++--------
.../flink/table/functions/SpecializedFunction.java | 69 +++
.../table/functions/UserDefinedFunctionHelper.java | 54 +++
.../table/types/inference/InputTypeStrategies.java | 14 +
.../table/types/inference/TypeStrategies.java | 16 +-
...rategy.java => CommonArgumentTypeStrategy.java} | 39 +-
.../types/logical/utils/LogicalTypeUtils.java | 1 +
.../flink/table/types/utils/DataTypeUtils.java | 8 +-
.../types/inference/InputTypeStrategiesTest.java | 10 +-
.../catalog/FunctionCatalogOperatorTable.java | 13 +-
.../converter/FunctionDefinitionConvertRule.java | 7 +-
.../functions/aggfunctions/CollectAggFunction.java | 9 +-
.../aggfunctions/FirstValueAggFunction.java | 10 +-
.../FirstValueWithRetractAggFunction.java | 8 +-
.../aggfunctions/InternalAggregateFunction.java | 54 ---
.../aggfunctions/LastValueAggFunction.java | 10 +-
.../LastValueWithRetractAggFunction.java | 8 +-
.../ListAggWithRetractAggFunction.java | 8 +-
.../ListAggWsWithRetractAggFunction.java | 13 +-
.../aggfunctions/MaxWithRetractAggFunction.java | 9 +-
.../aggfunctions/MinWithRetractAggFunction.java | 9 +-
.../inference/OperatorBindingCallContext.java | 24 +-
.../inference/TypeInferenceReturnInference.java | 2 +-
.../planner/codegen/LookupJoinCodeGenerator.scala | 17 +-
.../codegen/calls/BridgingSqlFunctionCallGen.scala | 27 +-
.../planner/plan/utils/AggFunctionFactory.scala | 24 +-
.../table/planner/plan/utils/AggregateUtil.scala | 32 +-
.../table/planner/plan/utils/PythonUtil.scala | 5 +-
.../planner/functions/MiscFunctionsITCase.java | 93 +++++
.../planner/runtime/stream/sql/FunctionITCase.java | 66 +++
.../aggregate/BuiltInAggregateFunction.java | 125 ++++++
.../functions/scalar/BuiltInScalarFunction.java | 116 ++++++
.../runtime/functions/scalar/IfNullFunction.java | 30 +-
.../runtime/functions/scalar/TypeOfFunction.java | 86 ++++
.../functions/table/BuiltInTableFunction.java | 116 ++++++
39 files changed, 1548 insertions(+), 351 deletions(-)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SpecializedFunction.java
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{CommonTypeStrategy.java
=> CommonArgumentTypeStrategy.java} (57%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/InternalAggregateFunction.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/functions/MiscFunctionsITCase.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/aggregate/BuiltInAggregateFunction.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/scalar/BuiltInScalarFunction.java
copy
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/util/RecyclableIterator.java
=>
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/scalar/IfNullFunction.java
(55%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/scalar/TypeOfFunction.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/table/BuiltInTableFunction.java
