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/05/26 14:08:20 UTC
[flink] branch master updated (6095131 -> b2db9ec)
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 6095131 [FLINK-17802][kafka] Set offset commit only if group id is configured for new Kafka Table source
add 1cce2c5 [hotfix][table-common] Add logical type root/family argument strategies
add b2db9ec [FLINK-17936][table] Introduce new type inference for AS
No new revisions were added by this update.
Summary of changes:
.../functions/BuiltInFunctionDefinitions.java | 13 +-
.../table/types/inference/InputTypeStrategies.java | 36 ++++
.../strategies/FamilyArgumentTypeStrategy.java | 138 +++++++++++++++
.../strategies/RootArgumentTypeStrategy.java | 105 +++++++++++
.../types/inference/strategies/StrategyUtils.java | 192 +++++++++++++++++++++
.../flink/table/types/logical/DoubleType.java | 2 +
.../flink/table/types/logical/FloatType.java | 2 +
.../types/logical/utils/LogicalTypeChecks.java | 12 ++
.../types/inference/InputTypeStrategiesTest.java | 83 ++++++++-
.../expressions/PlannerExpressionConverter.scala | 8 -
.../planner/expressions/fieldExpression.scala | 43 -----
.../table/validation/CalcValidationTest.scala | 8 -
.../table/validation/CalcValidationTest.scala | 8 -
13 files changed, 581 insertions(+), 69 deletions(-)
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/FamilyArgumentTypeStrategy.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/RootArgumentTypeStrategy.java
create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/StrategyUtils.java