org.apache.drill.exec.store.sys.store.provider

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

public class ZookeeperPersistentStoreProvider
extends BasePersistentStoreProvider

Field Summary

Fields

Modifier and Type	Field and Description
static String	DRILL_EXEC_SYS_STORE_PROVIDER_ZK_BLOBROOT

Constructor Summary

Constructors

Constructor and Description
ZookeeperPersistentStoreProvider(DrillConfig config, org.apache.curator.framework.CuratorFramework curator)
ZookeeperPersistentStoreProvider(PersistentStoreRegistry<ZKClusterCoordinator> registry)

Method Summary

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.

Methods inherited from class org.apache.drill.exec.store.sys.store.provider.BasePersistentStoreProvider

start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DRILL_EXEC_SYS_STORE_PROVIDER_ZK_BLOBROOT

public static final String DRILL_EXEC_SYS_STORE_PROVIDER_ZK_BLOBROOT

See Also:

Constant Field Values

Constructor Detail

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 Detail

getOrCreateStore

public <V> PersistentStore<V> getOrCreateStore(PersistentStoreConfig<V> config)
                                        throws StoreException

Description copied from interface: PersistentStoreProvider

Gets or creates a persistent store for the given configuration. Note that implementors have liberty to cache previous store 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

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class BasePersistentStoreProvider

Throws:

Exception