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