This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b3292cb [hotfix] Use UTC when converting to/from SqlTimestamp and
TimestampString
add 6acd646 [FLINK-17084][table] Implement input type inference and
output type strategy for ARRAY/ROW/MAP built-in functions (#11701)
No new revisions were added by this update.
Summary of changes:
.../flink/table/utils/FunctionLookupMock.java | 17 +---
.../functions/BuiltInFunctionDefinitions.java | 33 +++---
.../table/types/inference/InputTypeStrategies.java | 29 ++++++
.../table/types/inference/TypeStrategies.java | 44 ++++++++
...peStrategy.java => ArrayInputTypeStrategy.java} | 46 +++++----
.../inference/strategies/MapInputTypeStrategy.java | 112 +++++++++++++++++++++
.../strategies/WildcardInputTypeStrategy.java | 11 +-
.../types/inference/InputTypeStrategiesTest.java | 69 ++++++++++++-
.../table/types/inference/TypeStrategiesTest.java | 40 +++++++-
.../converter/FunctionDefinitionConvertRule.java | 13 ++-
.../expressions/PlannerExpressionConverter.scala | 23 ++---
.../table/planner/expressions/collection.scala | 68 -------------
.../table/planner/expressions/ArrayTypeTest.scala | 9 ++
.../table/planner/expressions/MapTypeTest.scala | 9 ++
.../validation/ArrayTypeValidationTest.scala | 5 -
.../expressions/PlannerTypeInferenceUtilImpl.java | 4 +
.../table/validation/CalcValidationTest.scala | 13 ---
.../flink/table/expressions/ArrayTypeTest.scala | 1 +
.../validation/ArrayTypeValidationTest.scala | 5 -
.../validation/MapTypeValidationTest.scala | 5 -
20 files changed, 389 insertions(+), 167 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{WildcardInputTypeStrategy.java
=> ArrayInputTypeStrategy.java} (57%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MapInputTypeStrategy.java
