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