Package | Description |
---|---|
org.apache.flink.table.catalog | |
org.apache.flink.table.catalog.listener | |
org.apache.flink.table.factories |
Class and Description |
---|
CatalogModificationListener
A listener that is notified on specific catalog changed in catalog manager.
|
Class and Description |
---|
AlterTableEvent
When a table is altered, a
AlterTableEvent event will be created and fired. |
CatalogContext
Context for catalog which provides the name, factory identifier and configuration to identify the
same physical catalog for different logical catalog.
|
CatalogModificationEvent
The basic interface for catalog modification event, all database and table related events are
implements this interface.
|
CatalogModificationListener
A listener that is notified on specific catalog changed in catalog manager.
|
CatalogModificationListenerFactory.Context
Context provided when a listener is created.
|
CreateDatabaseEvent
When a database is created, a
CreateDatabaseEvent event will be created and fired. |
CreateTableEvent
When a table is created, a
CreateTableEvent event will be created and fired. |
DatabaseModificationEvent
Basic event for database modification such as create, alter and drop, it has the database name
and
CatalogDatabase . |
DropTableEvent
When a table is dropped, a
DropTableEvent event will be created and fired. |
TableModificationEvent
Base table event, provides column list, primary keys, partition keys, watermarks and properties
in CatalogBaseTable.
|
Class and Description |
---|
CatalogModificationListener
A listener that is notified on specific catalog changed in catalog manager.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.