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/13 13:08:45 UTC
[flink] branch master updated (818953a -> 7a490d8)

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 818953a  [hotfix][build] Remove redundant flink-test-utils-junit version/scope
     add 58a8846  [FLINK-15802][table] Bring input/output types of table functions closer
     add 7a490d8  [FLINK-15802][table] Support new type inference for table functions

No new revisions were added by this update.

Summary of changes:
 .../flink/table/functions/ScalarFunction.java      |   9 +-
 .../flink/table/functions/TableFunction.java       | 126 ++++++++----
 .../calcite/sql/validate/ProcedureNamespace.java   |  79 +++++++
 .../catalog/FunctionCatalogOperatorTable.java      |  29 ++-
 .../planner/plan/QueryOperationConverter.java      |   6 +-
 .../flink/table/planner/codegen/CodeGenUtils.scala |   9 +-
 .../planner/codegen/CollectorCodeGenerator.scala   |  91 ++++++++-
 .../planner/codegen/CorrelateCodeGenerator.scala   | 227 +++++++++------------
 .../table/planner/codegen/ExprCodeGenerator.scala  |   4 +-
 .../codegen/calls/BridgingSqlFunctionCallGen.scala | 190 +++++++++++++++--
 .../codegen/calls/TableFunctionCallGen.scala       | 110 +++++++++-
 .../planner/functions/utils/TableSqlFunction.scala |   8 +-
 .../nodes/physical/batch/BatchExecCorrelate.scala  |  23 +--
 .../physical/stream/StreamExecCorrelate.scala      |  19 +-
 .../plan/rules/logical/LogicalUnnestRule.scala     |   6 +-
 .../schema/DeferredTypeFlinkTableFunction.scala    |   7 +-
 .../planner/plan/schema/FlinkTableFunction.scala   |   5 +-
 .../plan/schema/TypedFlinkTableFunction.scala      |   5 +-
 .../table/planner/plan/utils/RelExplainUtil.scala  |  29 ++-
 .../planner/plan/utils/SetOpRewriteUtil.scala      |   9 +-
 .../planner/runtime/stream/sql/FunctionITCase.java | 149 ++++++++++++++
 .../planner/plan/batch/sql/SetOperatorsTest.xml    |   4 +-
 .../planner/plan/batch/table/CorrelateTest.xml     |  24 +--
 .../planner/plan/batch/table/SetOperatorsTest.xml  |   4 +-
 .../stringexpr/CorrelateStringExpressionTest.xml   |  32 +--
 .../rules/logical/RewriteIntersectAllRuleTest.xml  |   8 +-
 .../plan/rules/logical/RewriteMinusAllRuleTest.xml |   8 +-
 .../planner/plan/stream/sql/SetOperatorsTest.xml   |   4 +-
 .../plan/stream/table/ColumnFunctionsTest.xml      |   4 +-
 .../planner/plan/stream/table/CorrelateTest.xml    |  44 ++--
 .../calcite/sql/validate/ProcedureNamespace.java   |  79 +++++++
 .../table/runtime/collector/WrappingCollector.java |  30 ++-
 32 files changed, 1028 insertions(+), 353 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/sql/validate/ProcedureNamespace.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/validate/ProcedureNamespace.java
 copy flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/metrics/CountingCollector.java => flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/collector/WrappingCollector.java (59%)