org.apache.drill.exec.coord.store

Class CachingTransientStoreFactory

java.lang.Object

org.apache.drill.exec.coord.store.CachingTransientStoreFactory

All Implemented Interfaces:

AutoCloseable, TransientStoreFactory

public class CachingTransientStoreFactory
extends Object
implements TransientStoreFactory

Constructor Summary

Constructors

Constructor and Description
CachingTransientStoreFactory(TransientStoreFactory delegate)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

CachingTransientStoreFactory

public CachingTransientStoreFactory(TransientStoreFactory delegate)

Method Detail

getOrCreateStore

public <V> TransientStore<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

of

public static TransientStoreFactory of(TransientStoreFactory delegate)