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 46bb8ee [FLINK-18569][table] Support limit() for unordered tables
add 770120b [hotfix] Suppport ITEM for ROW types.
add fc4a3f1 [FLINK-18286] Fix type inference for GET & AT Calcite
functions
add bd52a83 [hotfix] Reuse a Flink cluster for expressions tests.
add 46579c3 [FLINK-18286] Implement type inference for GET/FLATTEN
No new revisions were added by this update.
Summary of changes:
.../functions/BuiltInFunctionDefinitions.java | 19 +-
.../table/types/inference/InputTypeStrategies.java | 6 +
.../table/types/inference/TypeStrategies.java | 30 +++
...egy.java => CompositeArgumentTypeStrategy.java} | 41 ++--
.../flink/table/types/utils/DataTypeUtils.java | 32 ++-
.../types/inference/InputTypeStrategiesTest.java | 27 ++-
.../inference/InputTypeStrategiesTestBase.java | 16 +-
.../table/types/inference/TypeStrategiesTest.java | 131 ++++++++++-
.../org/apache/calcite/sql/fun/SqlDotOperator.java | 194 +++++++++++++++
.../apache/calcite/sql/fun/SqlItemOperator.java | 157 ++++++++++++
.../calcite/sql/validate/AliasNamespace.java | 136 +++++++++++
.../calcite/sql/validate/ProcedureNamespace.java | 14 +-
.../table/planner/calcite/FlinkRexBuilder.java | 68 ++++++
.../table/planner/calcite/FlinkSqlNameMatcher.java | 100 ++++++++
.../table/planner/delegation/PlannerContext.java | 4 +-
.../planner/plan/FlinkCalciteCatalogReader.java | 5 +-
.../table/planner/calcite/FlinkTypeFactory.scala | 8 +-
.../table/planner/codegen/ExprCodeGenerator.scala | 11 +-
.../codegen/calls/BridgingSqlFunctionCallGen.scala | 19 +-
.../expressions/PlannerExpressionConverter.scala | 11 -
.../table/planner/expressions/composite.scala | 100 --------
.../expressions/BuiltInFunctionTestBase.java | 10 +
.../CompositeTypeAccessExpressionITCase.java | 262 +++++++++++++++++++++
.../metadata/AggCallSelectivityEstimatorTest.scala | 6 +-
.../plan/metadata/SelectivityEstimatorTest.scala | 6 +-
.../planner/plan/utils/FlinkRexUtilTest.scala | 6 +-
.../planner/plan/utils/RexNodeExtractorTest.scala | 54 +++--
.../table/planner/plan/utils/RexNodeTestBase.scala | 4 +-
28 files changed, 1288 insertions(+), 189 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{UseArgumentTypeStrategy.java
=> CompositeArgumentTypeStrategy.java} (52%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/fun/SqlDotOperator.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/fun/SqlItemOperator.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/validate/AliasNamespace.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/FlinkRexBuilder.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/FlinkSqlNameMatcher.java
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/composite.scala
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/expressions/CompositeTypeAccessExpressionITCase.java
