org.apache.paimon.flink

Class FlinkCatalog

java.lang.Object

org.apache.flink.table.catalog.AbstractCatalog

org.apache.paimon.flink.FlinkCatalog

All Implemented Interfaces:

org.apache.flink.table.catalog.Catalog

public class FlinkCatalog
extends org.apache.flink.table.catalog.AbstractCatalog

Catalog for paimon.

Constructor Summary

Constructors

Constructor and Description
FlinkCatalog(Catalog catalog, String name, String defaultDatabase, ClassLoader classLoader, Options options)

Method Summary

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)
protected Schema	buildPaimonSchema(Identifier identifier, org.apache.flink.table.catalog.CatalogBaseTable catalogTable, Map<String,String> options)
Catalog	catalog()
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)
static Schema	fromCatalogTable(org.apache.flink.table.catalog.CatalogBaseTable catalogTable)
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)
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.CatalogBaseTable	getTable(org.apache.flink.table.catalog.ObjectPath tablePath, long timestamp) Do not annotate with @override here to maintain compatibility with Flink 1.17-.
org.apache.flink.table.catalog.stats.CatalogColumnStatistics	getTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath)
org.apache.flink.table.catalog.stats.CatalogTableStatistics	getTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath)
protected boolean	handleMaterializedTableChange(org.apache.flink.table.catalog.TableChange change, List<SchemaChange> schemaChanges) Try handle change related to materialized table.
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)
static Identifier	toIdentifier(org.apache.flink.table.catalog.ObjectPath path)

Methods inherited from class org.apache.flink.table.catalog.AbstractCatalog

getDefaultDatabase, getName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.catalog.Catalog

bulkGetPartitionColumnStatistics, bulkGetPartitionStatistics, dropDatabase, getFunctionDefinitionFactory, getTableFactory, supportsManagedTable

Constructor Detail

FlinkCatalog

public FlinkCatalog(Catalog catalog,
                    String name,
                    String defaultDatabase,
                    ClassLoader classLoader,
                    Options options)

Method Detail

catalog

public Catalog catalog()

getFactory

public Optional<org.apache.flink.table.factories.Factory> getFactory()

listDatabases

public List<String> listDatabases()
                           throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

databaseExists

public boolean databaseExists(String databaseName)
                       throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

getDatabase

public org.apache.flink.table.catalog.CatalogDatabase getDatabase(String databaseName)
                                                           throws org.apache.flink.table.catalog.exceptions.CatalogException,
                                                                  org.apache.flink.table.catalog.exceptions.DatabaseNotExistException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

org.apache.flink.table.catalog.exceptions.DatabaseNotExistException

createDatabase

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

Throws:

org.apache.flink.table.catalog.exceptions.DatabaseAlreadyExistException

org.apache.flink.table.catalog.exceptions.CatalogException

dropDatabase

public void dropDatabase(String name,
                         boolean ignoreIfNotExists,
                         boolean cascade)
                  throws org.apache.flink.table.catalog.exceptions.DatabaseNotEmptyException,
                         org.apache.flink.table.catalog.exceptions.DatabaseNotExistException,
                         org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.DatabaseNotEmptyException

org.apache.flink.table.catalog.exceptions.DatabaseNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

listTables

public List<String> listTables(String databaseName)
                        throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException,
                               org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.DatabaseNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

getTable

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

Throws:

org.apache.flink.table.catalog.exceptions.TableNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

getTable

public org.apache.flink.table.catalog.CatalogBaseTable getTable(org.apache.flink.table.catalog.ObjectPath tablePath,
                                                                long timestamp)
                                                         throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
                                                                org.apache.flink.table.catalog.exceptions.CatalogException

Do not annotate with @override here to maintain compatibility with Flink 1.17-.

Throws:

org.apache.flink.table.catalog.exceptions.TableNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

tableExists

public boolean tableExists(org.apache.flink.table.catalog.ObjectPath tablePath)
                    throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

dropTable

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

Throws:

org.apache.flink.table.catalog.exceptions.TableNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

createTable

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

Throws:

org.apache.flink.table.catalog.exceptions.TableAlreadyExistException

org.apache.flink.table.catalog.exceptions.DatabaseNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

buildPaimonSchema

protected Schema buildPaimonSchema(Identifier identifier,
                                   org.apache.flink.table.catalog.CatalogBaseTable catalogTable,
                                   Map<String,String> options)

handleMaterializedTableChange

protected boolean handleMaterializedTableChange(org.apache.flink.table.catalog.TableChange change,
                                                List<SchemaChange> schemaChanges)

Try handle change related to materialized table.

Returns:

true, if change can be identified as TableChange.MaterializedTableChange and is handled properly. Otherwise, false.

alterTable

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

Throws:

org.apache.flink.table.catalog.exceptions.TableNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

alterTable

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

Throws:

org.apache.flink.table.catalog.exceptions.TableNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

open

public final void open()
                throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

close

public final void close()
                 throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

fromCatalogTable

public static Schema fromCatalogTable(org.apache.flink.table.catalog.CatalogBaseTable catalogTable)

toIdentifier

public static Identifier toIdentifier(org.apache.flink.table.catalog.ObjectPath path)

alterDatabase

public final void alterDatabase(String name,
                                org.apache.flink.table.catalog.CatalogDatabase newDatabase,
                                boolean ignoreIfNotExists)
                         throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

renameTable

public final void renameTable(org.apache.flink.table.catalog.ObjectPath tablePath,
                              String newTableName,
                              boolean ignoreIfNotExists)
                       throws org.apache.flink.table.catalog.exceptions.CatalogException,
                              org.apache.flink.table.catalog.exceptions.TableNotExistException,
                              org.apache.flink.table.catalog.exceptions.TableAlreadyExistException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

org.apache.flink.table.catalog.exceptions.TableNotExistException

org.apache.flink.table.catalog.exceptions.TableAlreadyExistException

listViews

public final List<String> listViews(String databaseName)
                             throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException,
                                    org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.DatabaseNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

listPartitions

public final 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

Throws:

org.apache.flink.table.catalog.exceptions.TableNotExistException

org.apache.flink.table.catalog.exceptions.TableNotPartitionedException

org.apache.flink.table.catalog.exceptions.CatalogException

listPartitions

public final 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.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.TableNotExistException

org.apache.flink.table.catalog.exceptions.TableNotPartitionedException

org.apache.flink.table.catalog.exceptions.CatalogException

listPartitionsByFilter

public final 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.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

getPartition

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

Throws:

org.apache.flink.table.catalog.exceptions.PartitionNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

partitionExists

public final boolean partitionExists(org.apache.flink.table.catalog.ObjectPath tablePath,
                                     org.apache.flink.table.catalog.CatalogPartitionSpec partitionSpec)
                              throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

createPartition

public final 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.CatalogException,
                                  org.apache.flink.table.catalog.exceptions.PartitionAlreadyExistsException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

org.apache.flink.table.catalog.exceptions.PartitionAlreadyExistsException

dropPartition

public final 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

Throws:

org.apache.flink.table.catalog.exceptions.PartitionNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

alterPartition

public final 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.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

listFunctions

public final List<String> listFunctions(String dbName)
                                 throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

getFunction

public final 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

Throws:

org.apache.flink.table.catalog.exceptions.FunctionNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

functionExists

public final boolean functionExists(org.apache.flink.table.catalog.ObjectPath functionPath)
                             throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

createFunction

public final 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.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

alterFunction

public final 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.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

dropFunction

public final void dropFunction(org.apache.flink.table.catalog.ObjectPath functionPath,
                               boolean ignoreIfNotExists)
                        throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

getTableStatistics

public final org.apache.flink.table.catalog.stats.CatalogTableStatistics getTableStatistics(org.apache.flink.table.catalog.ObjectPath tablePath)
                                                                                     throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

getTableColumnStatistics

public final org.apache.flink.table.catalog.stats.CatalogColumnStatistics getTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath tablePath)
                                                                                            throws org.apache.flink.table.catalog.exceptions.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

getPartitionStatistics

public final 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.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

getPartitionColumnStatistics

public final 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.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

alterTableStatistics

public final 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.CatalogException,
                                       org.apache.flink.table.catalog.exceptions.TableNotExistException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

org.apache.flink.table.catalog.exceptions.TableNotExistException

alterTableColumnStatistics

public final 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.CatalogException,
                                             org.apache.flink.table.catalog.exceptions.TableNotExistException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

org.apache.flink.table.catalog.exceptions.TableNotExistException

alterPartitionStatistics

public final 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.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

alterPartitionColumnStatistics

public final 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.CatalogException

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException

listProcedures

public List<String> listProcedures(String dbName)
                            throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException,
                                   org.apache.flink.table.catalog.exceptions.CatalogException

Do not annotate with @override here to maintain compatibility with Flink 1.17-.

Throws:

org.apache.flink.table.catalog.exceptions.DatabaseNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

getProcedure

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

Do not annotate with @override here to maintain compatibility with Flink 1.17-.

Throws:

org.apache.flink.table.catalog.exceptions.ProcedureNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException