You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2020/02/05 08:54:13 UTC
[flink] branch master updated (73017a8 -> 5e6e851)
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 73017a8 [FLINK-15335] Replace `add-dependencies-for-IDEA` profile
add 2b2d6ac [hotfix][table-common] Fix invalid BYTES data type extraction
add 035092b [hotfix][table] Fix various type inference issues
add 75248b4 [hotfix][table-common] Add 'use argument' type strategy
add 5e6e851 [FLINK-15487][table] Update code generation for new type inference
No new revisions were added by this update.
Summary of changes:
.../table/types/extraction/DataTypeExtractor.java | 6 +-
.../types/extraction/utils/ExtractionUtils.java | 27 +++
.../extraction/utils/FunctionMappingExtractor.java | 74 +++++---
.../flink/table/types/inference/TypeInference.java | 15 ++
.../table/types/inference/TypeStrategies.java | 8 +
...eStrategy.java => UseArgumentTypeStrategy.java} | 25 +--
.../table/types/utils/ClassDataTypeConverter.java | 9 +-
.../types/extraction/DataTypeExtractorTest.java | 7 +-
.../extraction/TypeInferenceExtractorTest.java | 54 +++++-
.../table/types/inference/TypeStrategiesTest.java | 13 ++
.../inference/CallBindingCallContext.java | 3 +
.../inference/OperatorBindingCallContext.java | 3 +
.../flink/table/planner/codegen/CodeGenUtils.scala | 111 ++++++++----
.../table/planner/codegen/ExprCodeGenerator.scala | 40 +++--
.../table/planner/codegen/GenerateUtils.scala | 25 +--
.../planner/codegen/LookupJoinCodeGenerator.scala | 2 +-
.../planner/codegen/agg/ImperativeAggCodeGen.scala | 10 +-
.../codegen/agg/batch/AggCodeGenHelper.scala | 7 +-
.../codegen/calls/BridgingSqlFunctionCallGen.scala | 197 +++++++++++++++++++++
.../codegen/calls/ScalarFunctionCallGen.scala | 20 ++-
.../planner/runtime/stream/sql/FunctionITCase.java | 188 +++++++++++++++++++-
.../utils/TestCollectionTableFactory.scala | 6 +
22 files changed, 723 insertions(+), 127 deletions(-)
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{MissingTypeStrategy.java => UseArgumentTypeStrategy.java} (69%)
create mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/BridgingSqlFunctionCallGen.scala