Class ZookeeperPersistentStoreProvider
java.lang.Object
org.apache.drill.exec.store.sys.store.provider.BasePersistentStoreProvider
org.apache.drill.exec.store.sys.store.provider.ZookeeperPersistentStoreProvider
- All Implemented Interfaces:
AutoCloseable
,PersistentStoreProvider
- Direct Known Subclasses:
ZkPStoreProvider
-
Field Summary
-
Constructor Summary
ConstructorDescriptionZookeeperPersistentStoreProvider
(DrillConfig config, org.apache.curator.framework.CuratorFramework curator) -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
<V> PersistentStore<V>
getOrCreateStore
(PersistentStoreConfig<V> config) Gets or creates apersistent store
for the given configuration.<V> VersionedPersistentStore<V>
getOrCreateVersionedStore
(PersistentStoreConfig<V> config) Override this method if store supports versioning and return versioning instance.Methods inherited from class org.apache.drill.exec.store.sys.store.provider.BasePersistentStoreProvider
start
-
Field Details
-
DRILL_EXEC_SYS_STORE_PROVIDER_ZK_BLOBROOT
- See Also:
-
-
Constructor Details
-
ZookeeperPersistentStoreProvider
public ZookeeperPersistentStoreProvider(PersistentStoreRegistry<ZKClusterCoordinator> registry) throws StoreException - Throws:
StoreException
-
ZookeeperPersistentStoreProvider
public ZookeeperPersistentStoreProvider(DrillConfig config, org.apache.curator.framework.CuratorFramework curator) throws StoreException - Throws:
StoreException
-
-
Method Details
-
getOrCreateStore
public <V> PersistentStore<V> getOrCreateStore(PersistentStoreConfig<V> config) throws StoreException Description copied from interface:PersistentStoreProvider
Gets or creates apersistent store
for the given configuration. Note that implementors have liberty to cache previousstore
instances.- Type Parameters:
V
- store value type- Parameters:
config
- store configuration- Returns:
- persistent store instance
- Throws:
StoreException
- in case when unable to create store
-
getOrCreateVersionedStore
public <V> VersionedPersistentStore<V> getOrCreateVersionedStore(PersistentStoreConfig<V> config) throws StoreException Description copied from interface:PersistentStoreProvider
Override this method if store supports versioning and return versioning instance. By default, undefined version wrapper will be used.- Type Parameters:
V
- store value type- Parameters:
config
- store configuration- Returns:
- versioned persistent store instance
- Throws:
StoreException
- in case when unable to create store
-
close
- Specified by:
close
in interfaceAutoCloseable
- Overrides:
close
in classBasePersistentStoreProvider
- Throws:
Exception
-