org.wikimedia.eventutilities.flink.table.catalog

Class EventStreamCatalog

java.lang.Object

org.apache.flink.table.catalog.AbstractCatalog

org.apache.flink.table.catalog.GenericInMemoryCatalog

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

org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog

All Implemented Interfaces:

org.apache.flink.table.catalog.Catalog

public class EventStreamCatalog
extends AbstractEventStreamCatalog

Field Summary

Fields

Modifier and Type	Field and Description
static String	PLACEHOLDER

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

DEFAULT_DB

Constructor Summary

Constructors

Constructor and Description
EventStreamCatalog(String name, List<String> eventSchemasBaseUris, String eventStreamConfigUri, Map<String,String> httpRoutes, Map<String,String> options)

Method Summary

Modifier and Type	Method and Description
void	alterTable(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogBaseTable catalogBaseTable, boolean ignoreIfNotExists)
void	createTable(org.apache.flink.table.catalog.ObjectPath tablePath, org.apache.flink.table.catalog.CatalogBaseTable table, boolean ignoreIfExists)
boolean	databaseExists(String databaseName)
void	dropTable(org.apache.flink.table.catalog.ObjectPath objectPath, boolean ignoreIfNotExists)
org.apache.flink.table.catalog.CatalogBaseTable	getTable(org.apache.flink.table.catalog.ObjectPath tablePath)
List<String>	listTables(String databaseName)
void	open()
boolean	tableExists(org.apache.flink.table.catalog.ObjectPath tablePath)

Methods inherited from class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog

alterDatabase, alterPartition, alterPartitionColumnStatistics, alterPartitionStatistics, alterTableColumnStatistics, alterTableStatistics, createDatabase, createPartition, dropDatabase, dropPartition, getDatabase, getPartition, getPartitionColumnStatistics, getPartitionStatistics, getTableColumnStatistics, getTableStatistics, listDatabases, listPartitions, listPartitions, listPartitionsByFilter, listViews, partitionExists

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

alterFunction, close, createFunction, dropFunction, functionExists, getFunction, listFunctions, renameTable, supportsManagedTable

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

Field Detail

PLACEHOLDER

public static final String PLACEHOLDER

See Also:

Constant Field Values

Constructor Detail

EventStreamCatalog

public EventStreamCatalog(String name,
                          List<String> eventSchemasBaseUris,
                          String eventStreamConfigUri,
                          @Nullable
                          Map<String,String> httpRoutes,
                          Map<String,String> options)

Method Detail

open

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

Specified by:

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

Overrides:

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

Throws:

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

databaseExists

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

Specified by:

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

Overrides:

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

Throws:

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

Specified by:

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

Overrides:

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

Throws:

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

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

tableExists

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

Specified by:

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

Overrides:

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

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

Specified by:

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

Overrides:

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

Throws:

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

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

Specified by:

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

Overrides:

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

Throws:

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

dropTable

public void dropTable(org.apache.flink.table.catalog.ObjectPath objectPath,
                      boolean ignoreIfNotExists)
               throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
                      org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

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

Overrides:

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

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 catalogBaseTable,
                       boolean ignoreIfNotExists)
                throws org.apache.flink.table.catalog.exceptions.TableNotExistException,
                       org.apache.flink.table.catalog.exceptions.CatalogException

Specified by:

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

Overrides:

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

Throws:

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

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