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.
|
start
public static final String DRILL_EXEC_SYS_STORE_PROVIDER_ZK_BLOBROOT
public ZookeeperPersistentStoreProvider(PersistentStoreRegistry<ZKClusterCoordinator> registry) throws StoreException
StoreException
public ZookeeperPersistentStoreProvider(DrillConfig config, org.apache.curator.framework.CuratorFramework curator) throws StoreException
StoreException
public <V> PersistentStore<V> getOrCreateStore(PersistentStoreConfig<V> config) throws StoreException
PersistentStoreProvider
persistent 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
PersistentStoreProvider
V
- store value typeconfig
- store configurationStoreException
- in case when unable to create storepublic void close() throws Exception
close
in interface AutoCloseable
close
in class BasePersistentStoreProvider
Exception
Copyright © 1970 The Apache Software Foundation. All rights reserved.