[flink] branch master updated (1dff9e0 -> 386d742)

[ku...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 1dff9e0  [FLINK-12902][hadoop] Remove flink-shaded-yarn-tests
     add c1bde79  [FLINK-13071][table-planner-blink] Support more functions in RexNodeConverter.
     add 02ad3d2  [FLINK-13071][table-planner-blink] QueryOperationConverter in Blink planner support add kinds of QueryOperations.
     add 386d742  [FLINK-13071][table-planner-blink] Remove toRexNode methods from the PlannerExpressions in blink planner & add TableApi testcases.

No new revisions were added by this update.

Summary of changes:
 flink-table/flink-table-planner-blink/pom.xml      |   12 +
 .../flink/table/expressions/RexNodeConverter.java  |  846 +++++++++--
 .../flink/table/expressions/RexNodeExpression.java |   70 +
 .../table/expressions/SqlAggFunctionVisitor.java   |  100 ++
 .../flink/table/plan/QueryOperationConverter.java  |  335 ++++-
 .../apache/flink/table/api/TableEnvironment.scala  |    2 +-
 .../org/apache/flink/table/api/scala/package.scala |   70 -
 .../flink/table/calcite/FlinkRelBuilder.scala      |   47 +-
 .../table/expressions/PlannerExpression.scala      |   15 +-
 .../flink/table/expressions/aggregations.scala     |  233 +---
 .../flink/table/expressions/arithmetic.scala       |   39 +-
 .../org/apache/flink/table/expressions/call.scala  |   63 +-
 .../org/apache/flink/table/expressions/cast.scala  |   15 -
 .../flink/table/expressions/collection.scala       |   61 -
 .../flink/table/expressions/comparison.scala       |   63 +-
 .../apache/flink/table/expressions/composite.scala |    8 -
 .../flink/table/expressions/fieldExpression.scala  |   27 +-
 .../flink/table/expressions/hashExpressions.scala  |   31 -
 .../apache/flink/table/expressions/literals.scala  |   67 +-
 .../org/apache/flink/table/expressions/logic.scala |   22 -
 .../flink/table/expressions/mathExpressions.scala  |  137 --
 .../apache/flink/table/expressions/ordering.scala  |   11 -
 .../table/expressions/stringExpressions.scala      |   95 --
 .../apache/flink/table/expressions/subquery.scala  |   19 -
 .../apache/flink/table/expressions/symbols.scala   |   11 +-
 .../org/apache/flink/table/expressions/time.scala  |   49 +-
 .../flink/table/expressions/windowProperties.scala |    8 +-
 .../functions/utils/UserDefinedFunctionUtils.scala |    2 -
 .../plan/util/JavaUserDefinedAggFunctions.java     |  152 ++
 .../runtime/utils/JavaUserDefinedAggFunctions.java |  428 ++++++
 .../utils/userDefinedScalarFunctions.scala         |   38 +
 .../runtime/batch/table/AggregationITCase.scala    |  484 +++++++
 .../table/runtime/batch/table/CalcITCase.scala     |  653 +++++++++
 .../runtime/batch/table/CorrelateITCase.scala      |  402 ++++++
 .../runtime/batch/table/GroupWindowITCase.scala    |  343 +++++
 .../table/runtime/batch/table/JoinITCase.scala     |  392 ++++++
 .../runtime/batch/table/OverWindowITCase.scala     | 1403 +++++++++++++++++++
 .../runtime/batch/table/SetOperatorsITCase.scala   |  199 +++
 .../table/runtime/batch/table/SortITCase.scala     |   91 ++
 .../runtime/stream/table/AggregateITCase.scala     |  400 ++++++
 .../table/runtime/stream/table/CalcITCase.scala    |  484 +++++++
 .../table/runtime/stream/table/JoinITCase.scala    | 1470 ++++++++++++++++++++
 .../runtime/stream/table/RetractionITCase.scala    |  168 +++
 .../table/runtime/utils/BatchTableEnvUtil.scala    |   10 +-
 .../flink/table/runtime/utils/BatchTestBase.scala  |   19 +
 .../runtime/utils/CollectionBatchExecTable.scala   |  404 ++++++
 .../flink/table/runtime/utils/SortTestUtils.scala  |   57 +
 .../flink/table/runtime/utils/TestData.scala       |   95 ++
 .../flink/table/util/UserDefinedAggFunctions.scala |  187 +++
 tools/maven/suppressions.xml                       |    5 +-
 50 files changed, 9202 insertions(+), 1140 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/expressions/RexNodeExpression.java
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/expressions/SqlAggFunctionVisitor.java
 delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/api/scala/package.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/runtime/utils/JavaUserDefinedAggFunctions.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/table/AggregationITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/table/CalcITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/table/CorrelateITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/table/GroupWindowITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/table/JoinITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/table/OverWindowITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/table/SetOperatorsITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/table/SortITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/stream/table/AggregateITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/stream/table/CalcITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/stream/table/JoinITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/stream/table/RetractionITCase.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/utils/CollectionBatchExecTable.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/utils/SortTestUtils.scala
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/util/UserDefinedAggFunctions.scala