Package org.apache.drill.exec.coord.store

Class BaseTransientStore<V>

java.lang.Object

org.apache.drill.exec.coord.store.BaseTransientStore<V>

All Implemented Interfaces:

AutoCloseable, TransientStore<V>

Direct Known Subclasses:

MapBackedStore, ZkEphemeralStore

public abstract class BaseTransientStore<V>
extends Object
implements TransientStore<V>

Field Summary

Fields

Modifier and Type	Field	Description
protected final TransientStoreConfig<V>	config

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseTransientStore(TransientStoreConfig<V> config)

Method Summary

Modifier and Type	Method	Description
void	addListener(TransientStoreListener listener)	Adds a listener that observes store events.
protected void	fireListeners(TransientStoreEvent<?> event)
TransientStoreConfig<V>	getConfig()
Iterator<String>	keys()	Returns an iterator of keys.
void	removeListener(TransientStoreListener listener)	Removes the given listener from this store if exists, has no effect otherwise.
Iterator<V>	values()	Returns an iterator of values.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.AutoCloseable

close

Methods inherited from interface org.apache.drill.exec.coord.store.TransientStore

entries, get, put, putIfAbsent, remove, size

Field Details

config

protected final TransientStoreConfig<V> config

Constructor Details

BaseTransientStore

protected BaseTransientStore(TransientStoreConfig<V> config)

Method Details

getConfig

public TransientStoreConfig<V> getConfig()

keys

public Iterator<String> keys()

Description copied from interface: TransientStore

Returns an iterator of keys.

Specified by:

keys in interface TransientStore<V>

values

public Iterator<V> values()

Description copied from interface: TransientStore

Returns an iterator of values.

Specified by:

values in interface TransientStore<V>

fireListeners

protected void fireListeners(TransientStoreEvent<?> event)

addListener

public void addListener(TransientStoreListener listener)

Description copied from interface: TransientStore

Adds a listener that observes store events. Note that i) Calling this method with the same listener instance more than once has no effect. ii) Listeners are not necessarily invoked from the calling thread. Consumer should consider thread safety issues. iii) Subclasses might hold a strong reference to the listener. It is important that consumer removes its listener once it is done observing events.

Specified by:

addListener in interface TransientStore<V>

See Also:

• TransientStore.removeListener(TransientStoreListener)

removeListener

public void removeListener(TransientStoreListener listener)

Description copied from interface: TransientStore

Removes the given listener from this store if exists, has no effect otherwise.

Specified by:

removeListener in interface TransientStore<V>