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/06/10 16:30:56 UTC
[flink] branch master updated (4555ad9 -> fcab7b3)
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 4555ad9 [FLINK-18188][Runtime] Derive JM Off-Heap memory from configured Total Flink Memory minus JVM Heap
add 6ca803f [hotfix][table-common] Implement first type strategy
add 0a0b4a4 [hotfix][table-common] Add a common type strategy
add fcab7b3 [FLINK-13784][table] Implement type inference for math functions
No new revisions were added by this update.
Summary of changes:
.../flink/table/api/internal/BaseExpressions.java | 6 +-
.../operations/utils/ValuesOperationFactory.java | 6 +-
.../table/functions/BuiltInFunctionDefinition.java | 24 +-
.../functions/BuiltInFunctionDefinitions.java | 295 ++++++++++++---
.../table/types/inference/InputTypeStrategies.java | 21 +-
.../table/types/inference/TypeStrategies.java | 202 +++++++++++
.../strategies/CommonInputTypeStrategy.java | 6 +-
...ngTypeStrategy.java => CommonTypeStrategy.java} | 19 +-
.../strategies/FamilyArgumentTypeStrategy.java | 29 +-
...citTypeStrategy.java => FirstTypeStrategy.java} | 27 +-
.../inference/strategies/MapInputTypeStrategy.java | 6 +-
...eStrategy.java => MatchFamilyTypeStrategy.java} | 30 +-
.../flink/table/types/logical/LogicalType.java | 4 +-
.../table/types/logical/LogicalTypeFamily.java | 2 +
.../flink/table/types/logical/LogicalTypeRoot.java | 4 +
...Generalization.java => LogicalTypeMerging.java} | 91 ++++-
...izationTest.java => LogicalCommonTypeTest.java} | 17 +-
.../table/types/inference/TypeStrategiesTest.java | 57 ++-
.../catalog/FunctionCatalogOperatorTable.java | 7 +
.../converter/CustomizedConvertRule.java | 33 +-
.../expressions/converter/DirectConvertRule.java | 4 +-
.../functions/sql/FlinkSqlOperatorTable.java | 2 +-
.../table/planner/plan/type/FlinkReturnTypes.java | 36 +-
.../expressions/PlannerExpressionParserImpl.scala | 8 +-
.../table/planner/calcite/FlinkTypeSystem.scala | 33 +-
.../planner/codegen/calls/ScalarOperatorGens.scala | 13 +-
.../expressions/PlannerExpressionConverter.scala | 185 ----------
.../planner/expressions/ReturnTypeInference.scala | 217 -----------
.../table/planner/expressions/arithmetic.scala | 149 --------
.../planner/expressions/mathExpressions.scala | 401 ---------------------
.../flink/table/planner/expressions/time.scala | 67 +---
.../table/planner/typeutils/TypeCoercion.scala | 22 --
.../planner/typeutils/TypeInfoCheckUtils.scala | 139 +------
.../expressions/BuiltInFunctionTestBase.java | 6 +
.../planner/expressions/MathFunctionsITCase.java | 110 +++++-
.../planner/plan/stream/table/OverWindowTest.xml | 4 +-
.../table/planner/plan/stream/table/ValuesTest.xml | 52 +--
.../planner/calcite/FlinkTypeFactoryTest.scala | 5 +-
.../planner/expressions/ScalarFunctionsTest.scala | 139 -------
.../expressions/PlannerExpressionConverter.scala | 8 +-
.../expressions/PlannerExpressionParserImpl.scala | 8 +-
.../table/api/stream/table/OverWindowTest.scala | 2 +-
.../table/expressions/ScalarOperatorsTest.scala | 1 -
43 files changed, 904 insertions(+), 1593 deletions(-)
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{MissingTypeStrategy.java => CommonTypeStrategy.java} (63%)
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{ExplicitTypeStrategy.java => FirstTypeStrategy.java} (64%)
copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{ExplicitTypeStrategy.java => MatchFamilyTypeStrategy.java} (56%)
rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/{LogicalTypeGeneralization.java => LogicalTypeMerging.java} (88%)
rename flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/{LogicalTypeGeneralizationTest.java => LogicalCommonTypeTest.java} (96%)
delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/ReturnTypeInference.scala
delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/arithmetic.scala
delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/mathExpressions.scala