public class ZookeeperPersistentStoreProvider extends BasePersistentStoreProvider
| Modifier and Type | Field and Description |
|---|---|
static String |
DRILL_EXEC_SYS_STORE_PROVIDER_ZK_BLOBROOT |
| Constructor and Description |
|---|
ZookeeperPersistentStoreProvider(DrillConfig config,
org.apache.curator.framework.CuratorFramework curator) |
ZookeeperPersistentStoreProvider(PersistentStoreRegistry<ZKClusterCoordinator> registry) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
<V> PersistentStore<V> |
getOrCreateStore(PersistentStoreConfig<V> config)
Gets or creates a
persistent store for the given configuration. |
<V> VersionedPersistentStore<V> |
getOrCreateVersionedStore(PersistentStoreConfig<V> config)
Override this method if store supports versioning and return versioning instance.
|
startpublic static final String DRILL_EXEC_SYS_STORE_PROVIDER_ZK_BLOBROOT
public ZookeeperPersistentStoreProvider(PersistentStoreRegistry<ZKClusterCoordinator> registry) throws StoreException
StoreExceptionpublic ZookeeperPersistentStoreProvider(DrillConfig config, org.apache.curator.framework.CuratorFramework curator) throws StoreException
StoreExceptionpublic <V> PersistentStore<V> getOrCreateStore(PersistentStoreConfig<V> config) throws StoreException
PersistentStoreProviderpersistent store for the given configuration.
Note that implementors have liberty to cache previous store instances.V - store value typeconfig - store configurationStoreException - in case when unable to create storepublic <V> VersionedPersistentStore<V> getOrCreateVersionedStore(PersistentStoreConfig<V> config) throws StoreException
PersistentStoreProviderV - store value typeconfig - store configurationStoreException - in case when unable to create storepublic void close()
throws Exception
close in interface AutoCloseableclose in class BasePersistentStoreProviderExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.