@Internal public class GenericInMemoryCatalogStoreFactory extends Object implements CatalogStoreFactory
GenericInMemoryCatalogStore.CatalogStoreFactory.Context| Constructor and Description |
|---|
GenericInMemoryCatalogStoreFactory() |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close the CatalogStoreFactory.
|
CatalogStore |
createCatalogStore()
Creates a
CatalogStore instance from context information. |
String |
factoryIdentifier()
Returns a unique identifier among same factory interfaces.
|
void |
open(CatalogStoreFactory.Context context)
Initialize the CatalogStoreFactory.
|
Set<ConfigOption<?>> |
optionalOptions()
Returns a set of
ConfigOption that an implementation of this factory consumes in
addition to Factory.requiredOptions(). |
Set<ConfigOption<?>> |
requiredOptions()
Returns a set of
ConfigOption that an implementation of this factory requires in
addition to Factory.optionalOptions(). |
public CatalogStore createCatalogStore()
CatalogStoreFactoryCatalogStore instance from context information.createCatalogStore in interface CatalogStoreFactorypublic void open(CatalogStoreFactory.Context context)
CatalogStoreFactoryFor the use case of Flink SQL gateway, the open method will be called when starting SessionManager. It initializes common resources, such as a connection pool, for various catalog stores.
open in interface CatalogStoreFactorypublic void close()
CatalogStoreFactoryFor the use case of Flink SQL gateway, the close method will be called when closing SessionManager. It releases common resources, such as connection pool, after closing all catalog stores.
close in interface CatalogStoreFactorypublic String factoryIdentifier()
FactoryFor consistency, an identifier should be declared as one lower case word (e.g. kafka). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. elasticsearch-7).
factoryIdentifier in interface Factorypublic Set<ConfigOption<?>> requiredOptions()
FactoryConfigOption that an implementation of this factory requires in
addition to Factory.optionalOptions().
See the documentation of Factory for more information.
requiredOptions in interface Factorypublic Set<ConfigOption<?>> optionalOptions()
FactoryConfigOption that an implementation of this factory consumes in
addition to Factory.requiredOptions().
See the documentation of Factory for more information.
optionalOptions in interface FactoryCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.