public class FlinkGenericCatalog
extends org.apache.flink.table.catalog.AbstractCatalog
Constructor and Description |
---|
FlinkGenericCatalog(FlinkCatalog paimon,
org.apache.flink.table.catalog.Catalog flink) |
Modifier and Type | Method and Description |
---|---|
void |
alterDatabase(String name,
org.apache.flink.table.catalog.CatalogDatabase newDatabase,
boolean ignoreIfNotExists) |
void |
alterFunction(org.apache.flink.table.catalog.ObjectPath functionPath,
org.apache.flink.table.catalog.CatalogFunction newFunction,
boolean ignoreIfNotExists) |
void |
alterPartition(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
org.apache.flink.table.catalog.CatalogPartition newPartition,
boolean ignoreIfNotExists) |
void |
alterPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists) |
void |
alterPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
org.apache.flink.table.catalog.stats.CatalogTableStatistics partitionStatistics,
boolean ignoreIfNotExists) |
void |
alterTable(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogBaseTable newTable,
boolean ignoreIfNotExists) |
void |
alterTable(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogBaseTable newTable,
List<org.apache.flink.table.catalog.TableChange> tableChanges,
boolean ignoreIfNotExists) |
void |
alterTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics,
boolean ignoreIfNotExists) |
void |
alterTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.stats.CatalogTableStatistics tableStatistics,
boolean ignoreIfNotExists) |
List<org.apache.flink.table.catalog.stats.CatalogColumnStatistics> |
bulkGetPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
List<org.apache.flink.table.catalog.CatalogPartitionSpec> partitionSpecs) |
List<org.apache.flink.table.catalog.stats.CatalogTableStatistics> |
bulkGetPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
List<org.apache.flink.table.catalog.CatalogPartitionSpec> partitionSpecs) |
void |
close() |
void |
createDatabase(String name,
org.apache.flink.table.catalog.CatalogDatabase database,
boolean ignoreIfExists) |
void |
createFunction(org.apache.flink.table.catalog.ObjectPath functionPath,
org.apache.flink.table.catalog.CatalogFunction function,
boolean ignoreIfExists) |
void |
createPartition(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
org.apache.flink.table.catalog.CatalogPartition partition,
boolean ignoreIfExists) |
void |
createTable(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogBaseTable table,
boolean ignoreIfExists) |
boolean |
databaseExists(String databaseName) |
void |
dropDatabase(String name,
boolean ignoreIfNotExists,
boolean cascade) |
void |
dropFunction(org.apache.flink.table.catalog.ObjectPath functionPath,
boolean ignoreIfNotExists) |
void |
dropPartition(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec,
boolean ignoreIfNotExists) |
void |
dropTable(org.apache.flink.table.catalog.ObjectPath tablePath,
boolean ignoreIfNotExists) |
boolean |
functionExists(org.apache.flink.table.catalog.ObjectPath functionPath) |
org.apache.flink.table.catalog.CatalogDatabase |
getDatabase(String databaseName) |
Optional<org.apache.flink.table.factories.Factory> |
getFactory() |
org.apache.flink.table.catalog.CatalogFunction |
getFunction(org.apache.flink.table.catalog.ObjectPath functionPath) |
Optional<org.apache.flink.table.factories.FunctionDefinitionFactory> |
getFunctionDefinitionFactory() |
org.apache.flink.table.catalog.CatalogPartition |
getPartition(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
org.apache.flink.table.catalog.stats.CatalogColumnStatistics |
getPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
org.apache.flink.table.catalog.stats.CatalogTableStatistics |
getPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
org.apache.flink.table.procedures.Procedure |
getProcedure(org.apache.flink.table.catalog.ObjectPath procedurePath)
Do not annotate with
@override here to maintain compatibility with Flink 1.17-. |
org.apache.flink.table.catalog.CatalogBaseTable |
getTable(org.apache.flink.table.catalog.ObjectPath tablePath) |
org.apache.flink.table.catalog.stats.CatalogColumnStatistics |
getTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath) |
Optional<org.apache.flink.table.factories.TableFactory> |
getTableFactory() |
org.apache.flink.table.catalog.stats.CatalogTableStatistics |
getTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath) |
List<String> |
listDatabases() |
List<String> |
listFunctions(String dbName) |
List<org.apache.flink.table.catalog.CatalogPartitionSpec> |
listPartitions(org.apache.flink.table.catalog.ObjectPath tablePath) |
List<org.apache.flink.table.catalog.CatalogPartitionSpec> |
listPartitions(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
List<org.apache.flink.table.catalog.CatalogPartitionSpec> |
listPartitionsByFilter(org.apache.flink.table.catalog.ObjectPath tablePath,
List<org.apache.flink.table.expressions.Expression> filters) |
List<String> |
listProcedures(String dbName)
Do not annotate with
@override here to maintain compatibility with Flink 1.17-. |
List<String> |
listTables(String databaseName) |
List<String> |
listViews(String databaseName) |
void |
open() |
boolean |
partitionExists(org.apache.flink.table.catalog.ObjectPath tablePath,
org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) |
void |
renameTable(org.apache.flink.table.catalog.ObjectPath tablePath,
String newTableName,
boolean ignoreIfNotExists) |
boolean |
tableExists(org.apache.flink.table.catalog.ObjectPath tablePath) |
getDefaultDatabase, getName
public FlinkGenericCatalog(FlinkCatalog paimon, org.apache.flink.table.catalog.Catalog flink)
public void open() throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public void close() throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public Optional<org.apache.flink.table.factories.Factory> getFactory()
public Optional<org.apache.flink.table.factories.TableFactory> getTableFactory()
public Optional<org.apache.flink.table.factories.FunctionDefinitionFactory> getFunctionDefinitionFactory()
public List<String> listDatabases() throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.CatalogDatabase getDatabase(String databaseName) throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public boolean databaseExists(String databaseName) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public void createDatabase(String name, org.apache.flink.table.catalog.CatalogDatabase database, boolean ignoreIfExists) throws org.apache.flink.table.catalog.exceptions.DatabaseAlreadyExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseAlreadyExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void dropDatabase(String name, boolean ignoreIfNotExists, boolean cascade) throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.DatabaseNotEmptyException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.DatabaseNotEmptyException
org.apache.flink.table.catalog.exceptions.CatalogException
public void alterDatabase(String name, org.apache.flink.table.catalog.CatalogDatabase newDatabase, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<String> listTables(String databaseName) throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<String> listViews(String databaseName) throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.CatalogBaseTable getTable(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public boolean tableExists(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public void dropTable(org.apache.flink.table.catalog.ObjectPath tablePath, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void renameTable(org.apache.flink.table.catalog.ObjectPath tablePath, String newTableName, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.TableAlreadyExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.TableAlreadyExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void createTable(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogBaseTable table, boolean ignoreIfExists) throws org.apache.flink.table.catalog.exceptions.TableAlreadyExistException, org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableAlreadyExistException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void alterTable(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogBaseTable newTable, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void alterTable(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogBaseTable newTable, List<org.apache.flink.table.catalog.TableChange> tableChanges, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitions(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.TableNotPartitionedException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.TableNotPartitionedException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitions(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.TableNotPartitionedException, org.apache.flink.table.catalog.exceptions.PartitionSpecInvalidException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.TableNotPartitionedException
org.apache.flink.table.catalog.exceptions.PartitionSpecInvalidException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitionsByFilter(org.apache.flink.table.catalog.ObjectPath tablePath, List<org.apache.flink.table.expressions.Expression> filters) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.TableNotPartitionedException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.TableNotPartitionedException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.CatalogPartition getPartition(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public boolean partitionExists(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public void createPartition(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, org.apache.flink.table.catalog.CatalogPartition partition, boolean ignoreIfExists) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.TableNotPartitionedException, org.apache.flink.table.catalog.exceptions.PartitionSpecInvalidException, org.apache.flink.table.catalog.exceptions.PartitionAlreadyExistsException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.TableNotPartitionedException
org.apache.flink.table.catalog.exceptions.PartitionSpecInvalidException
org.apache.flink.table.catalog.exceptions.PartitionAlreadyExistsException
org.apache.flink.table.catalog.exceptions.CatalogException
public void dropPartition(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void alterPartition(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, org.apache.flink.table.catalog.CatalogPartition newPartition, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<String> listFunctions(String dbName) throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.CatalogFunction getFunction(org.apache.flink.table.catalog.ObjectPath functionPath) throws org.apache.flink.table.catalog.exceptions.FunctionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.FunctionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public boolean functionExists(org.apache.flink.table.catalog.ObjectPath functionPath) throws org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.CatalogException
public void createFunction(org.apache.flink.table.catalog.ObjectPath functionPath, org.apache.flink.table.catalog.CatalogFunction function, boolean ignoreIfExists) throws org.apache.flink.table.catalog.exceptions.FunctionAlreadyExistException, org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.FunctionAlreadyExistException
org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void alterFunction(org.apache.flink.table.catalog.ObjectPath functionPath, org.apache.flink.table.catalog.CatalogFunction newFunction, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.FunctionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.FunctionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void dropFunction(org.apache.flink.table.catalog.ObjectPath functionPath, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.FunctionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.FunctionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.stats.CatalogTableStatistics getTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.stats.CatalogColumnStatistics getTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.stats.CatalogTableStatistics getPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.catalog.stats.CatalogColumnStatistics getPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void alterTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.stats.CatalogTableStatistics tableStatistics, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void alterTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.TableNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException, org.apache.flink.table.catalog.exceptions.TablePartitionedException
org.apache.flink.table.catalog.exceptions.TableNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.TablePartitionedException
public void alterPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, org.apache.flink.table.catalog.stats.CatalogTableStatistics partitionStatistics, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public void alterPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec, org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics, boolean ignoreIfNotExists) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<org.apache.flink.table.catalog.stats.CatalogTableStatistics> bulkGetPartitionStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, List<org.apache.flink.table.catalog.CatalogPartitionSpec> partitionSpecs) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<org.apache.flink.table.catalog.stats.CatalogColumnStatistics> bulkGetPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath, List<org.apache.flink.table.catalog.CatalogPartitionSpec> partitionSpecs) throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
org.apache.flink.table.catalog.exceptions.PartitionNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public List<String> listProcedures(String dbName) throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
@override
here to maintain compatibility with Flink 1.17-.org.apache.flink.table.catalog.exceptions.DatabaseNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
public org.apache.flink.table.procedures.Procedure getProcedure(org.apache.flink.table.catalog.ObjectPath procedurePath) throws org.apache.flink.table.catalog.exceptions.ProcedureNotExistException, org.apache.flink.table.catalog.exceptions.CatalogException
@override
here to maintain compatibility with Flink 1.17-.org.apache.flink.table.catalog.exceptions.ProcedureNotExistException
org.apache.flink.table.catalog.exceptions.CatalogException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.