This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 17a32f85d66 [FLINK-37810] Update log4j to 2.24.3
add edeb7929172 [FLINK-37779][table] Support to get model via
CalciteCatalogReader (#26543)
No new revisions were added by this update.
Summary of changes:
.../apache/calcite/jdbc/SimpleCalciteSchema.java | 305 +++++++++++++++++++++
.../planner/catalog/CatalogCalciteSchema.java | 5 +
.../catalog/CatalogManagerCalciteSchema.java | 5 +
.../table/planner/catalog/CatalogSchemaModel.java | 88 ++++++
.../planner/catalog/DatabaseCalciteSchema.java | 12 +
.../flink/table/planner/catalog/FlinkSchema.java | 6 +
.../planner/plan/FlinkCalciteCatalogReader.java | 35 ++-
.../planner/catalog/DatabaseCalciteSchemaTest.java | 70 +++--
.../plan/FlinkCalciteCatalogReaderTest.java | 140 ++++++++++
9 files changed, 644 insertions(+), 22 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/calcite/jdbc/SimpleCalciteSchema.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaModel.java
