[flink] branch master updated (636a919 -> dc11218)

[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 636a919  [hotfix][core] Merge ClassLoaderUtils classes
     add b66cdba  [FLINK-13697][table-api] Removed deprecated ExternalCatalog API
     add dc11218  [FLINK-13697][table-api] Unified catalog manager operations

No new revisions were added by this update.

Summary of changes:
 docs/dev/table/common.md                           |  49 +--
 docs/dev/table/common.zh.md                        |  47 +--
 .../table/tests/test_environment_completeness.py   |   9 +-
 .../table/tests/test_table_environment_api.py      |   3 +-
 .../apache/flink/table/api/TableEnvironment.java   |  26 --
 .../table/api/internal/TableEnvironmentImpl.java   | 153 +++------
 .../apache/flink/table/catalog/CatalogManager.java | 342 +++++++--------------
 .../table/descriptors/ConnectTableDescriptor.java  |   4 +-
 .../flink/table/factories/TableFactoryUtil.java    |  14 +-
 .../table/operations/CatalogQueryOperation.java    |  13 +-
 .../flink/table/operations/QueryOperationTest.java |  12 +-
 .../flink/table/catalog/ExternalCatalog.java       |  68 ----
 .../flink/table/catalog/ExternalCatalogTable.java  | 148 ---------
 .../flink/table/catalog/ObjectIdentifier.java      |   4 +
 .../descriptors/ExternalCatalogDescriptor.java     |  63 ----
 .../ExternalCatalogDescriptorValidator.java        |  53 ----
 .../apache/flink/table/descriptors/Metadata.java   |  78 -----
 .../flink/table/descriptors/MetadataValidator.java |  41 ---
 .../table/descriptors/SchematicDescriptor.java     |  33 --
 .../apache/flink/table/descriptors/Statistics.java | 168 ----------
 .../table/descriptors/StatisticsValidator.java     | 126 --------
 .../table/factories/ExternalCatalogFactory.java    |  41 ---
 .../flink/table/factories/TableFactoryService.java |   7 +-
 .../descriptors/ExternalCatalogDescriptorTest.java | 101 ------
 .../flink/table/descriptors/MetadataTest.java      |  69 -----
 .../flink/table/descriptors/StatisticsTest.java    | 102 ------
 .../catalog/CatalogManagerCalciteSchema.java       |  11 +-
 .../planner/plan/QueryOperationConverter.java      |   8 +-
 .../table/planner/delegation/PlannerBase.scala     |  38 +--
 .../flink/table/planner/sinks/TableSinkUtils.scala |   9 +-
 .../flink/table/api/TableEnvironmentTest.scala     |   4 +-
 .../table/planner/catalog/CatalogTableITCase.scala |   5 +-
 .../table/catalog/CatalogManagerCalciteSchema.java |  22 +-
 .../flink/table/plan/QueryOperationConverter.java  |   8 +-
 .../flink/table/api/internal/TableEnvImpl.scala    | 181 +++--------
 .../flink/table/catalog/CrudExternalCatalog.scala  | 109 -------
 .../table/catalog/ExternalCatalogSchema.scala      | 138 ---------
 .../catalog/ExternalCatalogTableBuilder.scala      | 175 -----------
 .../flink/table/catalog/ExternalTableUtil.scala    |  75 -----
 .../table/catalog/InMemoryExternalCatalog.scala    | 126 --------
 .../apache/flink/table/planner/StreamPlanner.scala |  38 +--
 .../apache/flink/table/sinks/TableSinkUtils.scala  |  13 +-
 .../flink/table/catalog/CatalogManagerTest.java    |  41 +--
 .../table/catalog/CatalogStructureBuilder.java     | 129 +-------
 .../flink/table/catalog/PathResolutionTest.java    |  61 +---
 .../batch/table/JavaTableEnvironmentITCase.java    |   3 +-
 .../org.apache.flink.table.factories.TableFactory  |   1 -
 .../table/api/ExternalCatalogInsertTest.scala      | 108 -------
 .../flink/table/api/ExternalCatalogTest.scala      | 212 -------------
 .../TableEnvironmentValidationTest.scala           |   6 +-
 .../flink/table/catalog/CatalogTableITCase.scala   |   5 +-
 .../table/catalog/ExternalCatalogSchemaTest.scala  |  90 ------
 .../catalog/InMemoryExternalCatalogTest.scala      | 164 ----------
 .../table/descriptors/TestTableDescriptor.scala    |   5 +-
 .../ExternalCatalogFactoryServiceTest.scala        |  72 -----
 .../utils/TestExternalCatalogFactory.scala         |  64 ----
 .../flink/table/runtime/utils/CommonTestData.scala | 109 -------
 .../flink/table/utils/MockTableEnvironment.scala   |  10 +-
 58 files changed, 327 insertions(+), 3487 deletions(-)
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ExternalCatalog.java
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ExternalCatalogTable.java
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ExternalCatalogDescriptor.java
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/ExternalCatalogDescriptorValidator.java
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/Metadata.java
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/MetadataValidator.java
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/SchematicDescriptor.java
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/Statistics.java
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/StatisticsValidator.java
 delete mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/ExternalCatalogFactory.java
 delete mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/descriptors/ExternalCatalogDescriptorTest.java
 delete mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/descriptors/MetadataTest.java
 delete mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/descriptors/StatisticsTest.java
 delete mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/catalog/CrudExternalCatalog.scala
 delete mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogSchema.scala
 delete mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTableBuilder.scala
 delete mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/catalog/ExternalTableUtil.scala
 delete mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/catalog/InMemoryExternalCatalog.scala
 delete mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/ExternalCatalogInsertTest.scala
 delete mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/ExternalCatalogTest.scala
 delete mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/catalog/ExternalCatalogSchemaTest.scala
 delete mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/catalog/InMemoryExternalCatalogTest.scala
 delete mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/factories/ExternalCatalogFactoryServiceTest.scala
 delete mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/factories/utils/TestExternalCatalogFactory.scala