Package org.apache.flink.table.catalog
Class AbstractCatalogStore
- java.lang.Object
-
- org.apache.flink.table.catalog.AbstractCatalogStore
-
- All Implemented Interfaces:
CatalogStore
- Direct Known Subclasses:
FileCatalogStore
,GenericInMemoryCatalogStore
@Internal public abstract class AbstractCatalogStore extends Object implements CatalogStore
The AbstractCatalogStore class is an abstract base class for implementing a catalog store.
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
isOpen
Catalog store state.
-
Constructor Summary
Constructors Constructor Description AbstractCatalogStore()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
checkOpenState()
Checks whether the catalog store is currently open.void
close()
Closes the catalog store.void
open()
Opens the catalog store.-
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.CatalogStore
contains, getCatalog, listCatalogs, removeCatalog, storeCatalog
-
-
-
-
Method Detail
-
open
public void open()
Opens the catalog store.- Specified by:
open
in interfaceCatalogStore
-
close
public void close()
Closes the catalog store.- Specified by:
close
in interfaceCatalogStore
-
checkOpenState
protected void checkOpenState()
Checks whether the catalog store is currently open.- Throws:
IllegalStateException
- if the store is closed
-
-