[flink] branch master updated (e3c6885 -> 51724b7)

[dw...@apache.org]

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 e3c6885  [FLINK-12835][tests] Fix wrong conversion of ManualClock bug
     add e4635d7  [FLINK-12827][table-planner] Extract Optimizer from TableEnvImpl
     add 1737f1e  [FLINK-12798][table-planner] Extracted the logic of converting from a Row type info to expected type
     add 51724b7  [FLINK-12831][table-planner][table-api-java] Split FunctionCatalog into Flink & Calcite specific parts

No new revisions were added by this update.

Summary of changes:
 .../flink/table/catalog/FunctionCatalog.java       | 109 +++++
 .../table/expressions/LookupCallResolver.java      |   4 +-
 .../catalog/FunctionDefinitionCatalog.java         |   4 +-
 .../table/functions/UserFunctionsTypeHelper.java   | 176 ++++++++
 .../catalog/FunctionCatalogOperatorTable.java      | 139 ++++++
 .../planner/PlanningConfigurationBuilder.java      |  13 +-
 .../apache/flink/table/api/BatchTableEnvImpl.scala |  85 ++--
 .../flink/table/api/StreamTableEnvImpl.scala       | 483 ++++++---------------
 .../org/apache/flink/table/api/TableEnvImpl.scala  | 398 +----------------
 .../flink/table/api/scala/expressionDsl.scala      |  22 +-
 .../table/calcite/RelTimeIndicatorConverter.scala  |   2 +-
 .../BasicOperatorTable.scala}                      | 109 +----
 .../flink/table/codegen/MatchCodeGenerator.scala   |   2 +-
 .../flink/table/expressions/ExpressionBridge.scala |   4 +-
 .../org/apache/flink/table/expressions/call.scala  |   4 +-
 .../functions/utils/UserDefinedFunctionUtils.scala | 115 -----
 .../apache/flink/table/plan/BatchOptimizer.scala   |  69 +++
 .../org/apache/flink/table/plan/Optimizer.scala    | 264 +++++++++++
 .../apache/flink/table/plan/StreamOptimizer.scala  | 126 ++++++
 .../rules/common/LogicalWindowAggregateRule.scala  |   2 +-
 .../plan/rules/common/WindowPropertiesRule.scala   |   2 +-
 .../DataSetLogicalWindowAggregateRule.scala        |   2 +-
 .../DataStreamLogicalWindowAggregateRule.scala     |   2 +-
 .../PushFilterIntoTableSourceScanRule.scala        |   2 +-
 .../table/plan/util/RexProgramExtractor.scala      |  23 +-
 .../apache/flink/table/planner/Conversions.scala   | 151 +++++++
 .../table/planner/DataStreamConversions.scala      | 227 ++++++++++
 .../table/runtime/aggregate/AggregateUtil.scala    |   4 +-
 .../api/stream/StreamTableEnvironmentTest.scala    |  25 +-
 .../flink/table/api/stream/sql/AggregateTest.scala |   4 +-
 .../validation/OverWindowValidationTest.scala      |   5 +-
 .../expressions/utils/ExpressionTestBase.scala     |   4 +-
 .../table/match/PatternTranslatorTestBase.scala    |   3 +-
 .../flink/table/plan/RetractionRulesTest.scala     |   3 +-
 .../flink/table/plan/RexProgramExtractorTest.scala |   2 +-
 .../flink/table/plan/UpdatingPlanCheckerTest.scala |   3 +-
 .../table/runtime/harness/HarnessTestBase.scala    |  11 +-
 .../apache/flink/table/utils/TableTestBase.scala   |  21 +-
 38 files changed, 1561 insertions(+), 1063 deletions(-)
 create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionCatalog.java
 create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/functions/UserFunctionsTypeHelper.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog/FunctionCatalogOperatorTable.java
 rename flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/{validate/FunctionCatalog.scala => catalog/BasicOperatorTable.scala} (77%)
 create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/BatchOptimizer.scala
 create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/Optimizer.scala
 create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/StreamOptimizer.scala
 create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/Conversions.scala
 create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/DataStreamConversions.scala