org.apache.drill.exec.coord.zk

Class ZkTransientStoreFactory

java.lang.Object

org.apache.drill.exec.coord.zk.ZkTransientStoreFactory

All Implemented Interfaces:

AutoCloseable, TransientStoreFactory

public class ZkTransientStoreFactory
extends Object
implements TransientStoreFactory

Constructor Summary

Constructors

Constructor and Description
ZkTransientStoreFactory(org.apache.curator.framework.CuratorFramework curator)

Method Summary

Modifier and Type	Method and Description
void	close()
<V> ZkEphemeralStore<V>	getOrCreateStore(TransientStoreConfig<V> config) Returns a transient store instance for the given configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkTransientStoreFactory

public ZkTransientStoreFactory(org.apache.curator.framework.CuratorFramework curator)

Method Detail

getOrCreateStore

public <V> ZkEphemeralStore<V> getOrCreateStore(TransientStoreConfig<V> config)

Description copied from interface: TransientStoreFactory

Returns a transient store instance for the given configuration. Note that implementors have liberty to cache previous store instances.

Specified by:

getOrCreateStore in interface TransientStoreFactory

Type Parameters:

V - store value type

Parameters:

config - store configuration

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception