org.wikimedia.eventutilities.flink.table.catalog

Class AbstractEventStreamCatalog

java.lang.Object

org.apache.flink.table.catalog.AbstractCatalog

org.apache.flink.table.catalog.GenericInMemoryCatalog

org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog

All Implemented Interfaces:

org.apache.flink.table.catalog.Catalog

Direct Known Subclasses:

EventStreamCatalog

public abstract class AbstractEventStreamCatalog
extends org.apache.flink.table.catalog.GenericInMemoryCatalog

Contains override methods for Catalog that are unsupported.

Field Summary

Fields inherited from class org.apache.flink.table.catalog.GenericInMemoryCatalog

DEFAULT_DB

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEventStreamCatalog(String name)
protected	AbstractEventStreamCatalog(String name, String defaultDatabase)

Method Summary

Modifier and Type	Method and Description
void	alterDatabase(String s, org.apache.flink.table.catalog.CatalogDatabase catalogDatabase, boolean b)
void	alterPartition(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec, org.apache.flink.table.catalog.CatalogPartition catalogPartition, boolean b)
void	alterPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec, org.apache.flink.table.catalog.stats.CatalogColumnStatistics catalogColumnStatistics, boolean b)
void	alterPartitionStatistics(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec, org.apache.flink.table.catalog.stats.CatalogTableStatistics catalogTableStatistics, boolean b)
void	alterTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.stats.CatalogColumnStatistics catalogColumnStatistics, boolean b)
void	alterTableStatistics(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.stats.CatalogTableStatistics catalogTableStatistics, boolean b)
void	createDatabase(String s, org.apache.flink.table.catalog.CatalogDatabase catalogDatabase, boolean b)
void	createPartition(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec, org.apache.flink.table.catalog.CatalogPartition catalogPartition, boolean b)
void	dropDatabase(String s, boolean b, boolean b1)
void	dropPartition(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec, boolean b)
org.apache.flink.table.catalog.CatalogDatabase	getDatabase(String s)
org.apache.flink.table.catalog.CatalogPartition	getPartition(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)
org.apache.flink.table.catalog.stats.CatalogColumnStatistics	getPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)
org.apache.flink.table.catalog.stats.CatalogTableStatistics	getPartitionStatistics(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)
org.apache.flink.table.catalog.stats.CatalogColumnStatistics	getTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath objectPath)
org.apache.flink.table.catalog.stats.CatalogTableStatistics	getTableStatistics(org.apache.flink.table.catalog.ObjectPath objectPath)
List<String>	listDatabases()
List<org.apache.flink.table.catalog.CatalogPartitionSpec>	listPartitions(org.apache.flink.table.catalog.ObjectPath objectPath)
List<org.apache.flink.table.catalog.CatalogPartitionSpec>	listPartitions(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)
List<org.apache.flink.table.catalog.CatalogPartitionSpec>	listPartitionsByFilter(org.apache.flink.table.catalog.ObjectPath objectPath, List<org.apache.flink.table.expressions.Expression> list)
List<String>	listViews(String s)
boolean	partitionExists(org.apache.flink.table.catalog.ObjectPath objectPath, org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)

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

alterFunction, alterTable, close, createFunction, createTable, databaseExists, dropFunction, dropTable, functionExists, getFunction, getTable, listFunctions, listTables, open, renameTable, supportsManagedTable, tableExists

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

alterTable, bulkGetPartitionColumnStatistics, bulkGetPartitionStatistics, dropDatabase, getFactory, getFunctionDefinitionFactory, getProcedure, getTable, getTableFactory, listProcedures

Constructor Detail

AbstractEventStreamCatalog

protected AbstractEventStreamCatalog(String name)

AbstractEventStreamCatalog

protected AbstractEventStreamCatalog(String name,
                                     String defaultDatabase)

Method Detail

listDatabases

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

Specified by:

listDatabases in interface org.apache.flink.table.catalog.Catalog

Overrides:

listDatabases in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

getDatabase

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

Specified by:

getDatabase in interface org.apache.flink.table.catalog.Catalog

Overrides:

getDatabase in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

createDatabase

public void createDatabase(String s,
                           org.apache.flink.table.catalog.CatalogDatabase catalogDatabase,
                           boolean b)
                    throws org.apache.flink.table.catalog.exceptions.DatabaseAlreadyExistException,
                           org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

createDatabase in interface org.apache.flink.table.catalog.Catalog

Overrides:

createDatabase in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

dropDatabase

public void dropDatabase(String s,
                         boolean b,
                         boolean b1)
                  throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException,
                         org.apache.flink.table.catalog.exceptions.DatabaseNotEmptyException,
                         org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

dropDatabase in interface org.apache.flink.table.catalog.Catalog

Overrides:

dropDatabase in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

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

alterDatabase

public void alterDatabase(String s,
                          org.apache.flink.table.catalog.CatalogDatabase catalogDatabase,
                          boolean b)
                   throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException,
                          org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

alterDatabase in interface org.apache.flink.table.catalog.Catalog

Overrides:

alterDatabase in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

listViews

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

Specified by:

listViews in interface org.apache.flink.table.catalog.Catalog

Overrides:

listViews in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

listPartitions

public List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitions(org.apache.flink.table.catalog.ObjectPath objectPath)
                                                                         throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
                                                                                org.apache.flink.table.catalog.exceptions.TableNotPartitionedException,
                                                                                org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

listPartitions in interface org.apache.flink.table.catalog.Catalog

Overrides:

listPartitions in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

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

listPartitions

public List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitions(org.apache.flink.table.catalog.ObjectPath objectPath,
                                                                                org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)
                                                                         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

Specified by:

listPartitions in interface org.apache.flink.table.catalog.Catalog

Overrides:

listPartitions in class org.apache.flink.table.catalog.GenericInMemoryCatalog

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

listPartitionsByFilter

public List<org.apache.flink.table.catalog.CatalogPartitionSpec> listPartitionsByFilter(org.apache.flink.table.catalog.ObjectPath objectPath,
                                                                                        List<org.apache.flink.table.expressions.Expression> list)
                                                                                 throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
                                                                                        org.apache.flink.table.catalog.exceptions.TableNotPartitionedException,
                                                                                        org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

listPartitionsByFilter in interface org.apache.flink.table.catalog.Catalog

Overrides:

listPartitionsByFilter in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

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

getPartition

public org.apache.flink.table.catalog.CatalogPartition getPartition(org.apache.flink.table.catalog.ObjectPath objectPath,
                                                                    org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)
                                                             throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException,
                                                                    org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

getPartition in interface org.apache.flink.table.catalog.Catalog

Overrides:

getPartition in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

partitionExists

public boolean partitionExists(org.apache.flink.table.catalog.ObjectPath objectPath,
                               org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)
                        throws org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

partitionExists in interface org.apache.flink.table.catalog.Catalog

Overrides:

partitionExists in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

createPartition

public void createPartition(org.apache.flink.table.catalog.ObjectPath objectPath,
                            org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec,
                            org.apache.flink.table.catalog.CatalogPartition catalogPartition,
                            boolean b)
                     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

Specified by:

createPartition in interface org.apache.flink.table.catalog.Catalog

Overrides:

createPartition in class org.apache.flink.table.catalog.GenericInMemoryCatalog

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

dropPartition

public void dropPartition(org.apache.flink.table.catalog.ObjectPath objectPath,
                          org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec,
                          boolean b)
                   throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException,
                          org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

dropPartition in interface org.apache.flink.table.catalog.Catalog

Overrides:

dropPartition in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

alterPartition

public void alterPartition(org.apache.flink.table.catalog.ObjectPath objectPath,
                           org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec,
                           org.apache.flink.table.catalog.CatalogPartition catalogPartition,
                           boolean b)
                    throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException,
                           org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

alterPartition in interface org.apache.flink.table.catalog.Catalog

Overrides:

alterPartition in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

getTableStatistics

public org.apache.flink.table.catalog.stats.CatalogTableStatistics getTableStatistics(org.apache.flink.table.catalog.ObjectPath objectPath)
                                                                               throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
                                                                                      org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

getTableStatistics in interface org.apache.flink.table.catalog.Catalog

Overrides:

getTableStatistics in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

getTableColumnStatistics

public org.apache.flink.table.catalog.stats.CatalogColumnStatistics getTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath objectPath)
                                                                                      throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
                                                                                             org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

getTableColumnStatistics in interface org.apache.flink.table.catalog.Catalog

Overrides:

getTableColumnStatistics in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

getPartitionStatistics

public org.apache.flink.table.catalog.stats.CatalogTableStatistics getPartitionStatistics(org.apache.flink.table.catalog.ObjectPath objectPath,
                                                                                          org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)
                                                                                   throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException,
                                                                                          org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

getPartitionStatistics in interface org.apache.flink.table.catalog.Catalog

Overrides:

getPartitionStatistics in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

getPartitionColumnStatistics

public org.apache.flink.table.catalog.stats.CatalogColumnStatistics getPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath objectPath,
                                                                                                 org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec)
                                                                                          throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException,
                                                                                                 org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

getPartitionColumnStatistics in interface org.apache.flink.table.catalog.Catalog

Overrides:

getPartitionColumnStatistics in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

alterTableStatistics

public void alterTableStatistics(org.apache.flink.table.catalog.ObjectPath objectPath,
                                 org.apache.flink.table.catalog.stats.CatalogTableStatistics catalogTableStatistics,
                                 boolean b)
                          throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
                                 org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

alterTableStatistics in interface org.apache.flink.table.catalog.Catalog

Overrides:

alterTableStatistics in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

alterTableColumnStatistics

public void alterTableColumnStatistics(org.apache.flink.table.catalog.ObjectPath objectPath,
                                       org.apache.flink.table.catalog.stats.CatalogColumnStatistics catalogColumnStatistics,
                                       boolean b)
                                throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
                                       org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

alterTableColumnStatistics in interface org.apache.flink.table.catalog.Catalog

Overrides:

alterTableColumnStatistics in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

alterPartitionStatistics

public void alterPartitionStatistics(org.apache.flink.table.catalog.ObjectPath objectPath,
                                     org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec,
                                     org.apache.flink.table.catalog.stats.CatalogTableStatistics catalogTableStatistics,
                                     boolean b)
                              throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException,
                                     org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

alterPartitionStatistics in interface org.apache.flink.table.catalog.Catalog

Overrides:

alterPartitionStatistics in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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

alterPartitionColumnStatistics

public void alterPartitionColumnStatistics(org.apache.flink.table.catalog.ObjectPath objectPath,
                                           org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec,
                                           org.apache.flink.table.catalog.stats.CatalogColumnStatistics catalogColumnStatistics,
                                           boolean b)
                                    throws org.apache.flink.table.catalog.exceptions.PartitionNotExistException,
                                           org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

alterPartitionColumnStatistics in interface org.apache.flink.table.catalog.Catalog

Overrides:

alterPartitionColumnStatistics in class org.apache.flink.table.catalog.GenericInMemoryCatalog

Throws:

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

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