[flink] branch master updated (07efbde -> 8516751)

[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 07efbde  [hotfix][docs] fix config.zh.md file path error
     add 55b4d0b  [FLINK-11476] [SQL/TABLE] Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
     add 8516751  [FLINK-11476][table] Integrated CatalogManager with TableEnvironment

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/table/table.py                |  15 +-
 flink-python/pyflink/table/table_environment.py    | 114 +++++++
 .../table/tests/test_environment_completeness.py   |   9 +-
 .../client/gateway/local/ExecutionContext.java     |   8 +-
 .../client/gateway/local/LocalExecutorITCase.java  |  12 +-
 .../table/api/java/BatchTableEnvironment.java      |  12 +-
 .../table/api/java/StreamTableEnvironment.java     |  14 +-
 .../java/org/apache/flink/table/api/Table.java     |  36 ++-
 .../org/apache/flink/table/api/TableConfig.java    |  44 +++
 .../apache/flink/table/api/TableEnvironment.java   | 180 ++++++++++-
 .../apache/flink/table/catalog/CatalogManager.java | 340 ++++++++++++++++++++
 .../table/api/scala/BatchTableEnvironment.scala    |  16 +-
 .../table/api/scala/StreamTableEnvironment.scala   |  16 +-
 .../exceptions/DatabaseNotExistException.java      |   9 +-
 .../apache/flink/table/api/TableEnvironment.scala  |  33 +-
 .../org/apache/flink/table/api/TableImpl.scala     |   7 +-
 .../apache/calcite/jdbc/CalciteSchemaBuilder.java  |  27 +-
 .../flink/table/catalog/CalciteCatalogTable.java   |  88 ++++++
 .../flink/table/catalog/CatalogCalciteSchema.java  | 117 +++++++
 .../table/catalog/CatalogManagerCalciteSchema.java | 123 ++++++++
 .../apache/flink/table/catalog/CatalogReader.java  |  54 ++++
 .../flink/table/catalog/DatabaseCalciteSchema.java | 137 ++++++++
 .../planner/PlanningConfigurationBuilder.java      | 101 ++++--
 .../apache/flink/table/api/BatchTableEnvImpl.scala |   8 +-
 .../flink/table/api/StreamTableEnvImpl.scala       |   8 +-
 .../org/apache/flink/table/api/TableEnvImpl.scala  | 232 +++++++-------
 .../flink/table/api/java/BatchTableEnvImpl.scala   |  11 +-
 .../flink/table/api/java/StreamTableEnvImpl.scala  |  15 +-
 .../flink/table/api/scala/BatchTableEnvImpl.scala  |  11 +-
 .../flink/table/api/scala/StreamTableEnvImpl.scala |   9 +-
 .../org/apache/flink/table/api/tableImpl.scala     |  14 +-
 .../flink/table/calcite/FlinkPlannerImpl.scala     |  34 +-
 .../flink/table/catalog/CrudExternalCatalog.scala  |   6 +-
 .../table/catalog/ExternalCatalogSchema.scala      |  12 +-
 .../flink/table/catalog/ExternalTableUtil.scala    |  35 +--
 .../table/operations/OperationTreeBuilder.scala    |   2 +-
 .../nodes/dataset/DataSetWindowAggregate.scala     |   2 +-
 .../flink/table/catalog/CatalogManagerTest.java    | 151 +++++++++
 .../table/catalog/CatalogStructureBuilder.java     | 322 +++++++++++++++++++
 .../flink/table/catalog/PathResolutionTest.java    | 348 +++++++++++++++++++++
 .../catalog/TestExternalTableSourceFactory.java    |  93 ++++++
 .../batch/table/JavaTableEnvironmentITCase.java    |   3 +-
 .../org.apache.flink.table.factories.TableFactory  |   1 +
 .../table/api/ExternalCatalogInsertTest.scala      |  10 +-
 .../api/stream/StreamTableEnvironmentTest.scala    |   9 +-
 .../TableEnvironmentValidationTest.scala           |   5 +-
 .../api/validation/TableSinksValidationTest.scala  |   3 +-
 .../table/catalog/ExternalCatalogSchemaTest.scala  |   3 +-
 .../expressions/utils/ExpressionTestBase.scala     |  16 +-
 .../table/match/PatternTranslatorTestBase.scala    |   8 +-
 .../flink/table/utils/MockTableEnvironment.scala   |  18 +-
 .../apache/flink/table/utils/TableTestBase.scala   |  81 ++++-
 .../src/test/scala/resources/testFilter0.out       |   4 +-
 .../src/test/scala/resources/testFilter1.out       |   4 +-
 .../src/test/scala/resources/testFilterStream0.out |   4 +-
 .../src/test/scala/resources/testJoin0.out         |   8 +-
 .../src/test/scala/resources/testJoin1.out         |   8 +-
 .../src/test/scala/resources/testUnion0.out        |   8 +-
 .../src/test/scala/resources/testUnion1.out        |   8 +-
 .../src/test/scala/resources/testUnionStream0.out  |   8 +-
 60 files changed, 2662 insertions(+), 372 deletions(-)
 create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
 copy flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDeploymentException.java => flink-table/flink-table-planner/src/main/java/org/apache/calcite/jdbc/CalciteSchemaBuilder.java (64%)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog/CalciteCatalogTable.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog/CatalogCalciteSchema.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog/CatalogManagerCalciteSchema.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog/CatalogReader.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/catalog/DatabaseCalciteSchema.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/catalog/CatalogManagerTest.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/catalog/CatalogStructureBuilder.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/catalog/PathResolutionTest.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/catalog/TestExternalTableSourceFactory.java