software.chronicle.datagrid.internal.map

Class FilePerKeyValueStoreBackedKeyValueStore<K,V>

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

software.chronicle.datagrid.internal.map.FilePerKeyValueStoreBackedKeyValueStore<K,V>

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.ManagedCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, KeyValueStore<K,V>, Assetted<KeyValueStore<K,V>>, KeyedView

public final class FilePerKeyValueStoreBackedKeyValueStore<K,V>
extends net.openhft.chronicle.core.io.SimpleCloseable
implements KeyValueStore<K,V>

Nested Class Summary

Nested classes/interfaces inherited from interface software.chronicle.datagrid.map.KeyValueStore

KeyValueStore.Entry<K,V>

Field Summary

Fields inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

INIT

Constructor Summary

Constructors

Constructor and Description
FilePerKeyValueStoreBackedKeyValueStore(FilePerKeyValueStore filePerKeyValueStore, Function<K,String> keyToString, Function<V,net.openhft.chronicle.bytes.BytesStore> valueToBytesStore, Function<net.openhft.chronicle.bytes.BytesStore,V> bytesStoreToValue)

Method Summary

Modifier and Type	Method and Description
@NotNull Asset	asset()
void	clear()
boolean	containsValue(V value)
void	entriesFor(int segment, SubscriptionConsumer<MapEvent<K,V>> kvConsumer)
V	getAndPut(K key, V value)
V	getAndRemove(K key)
V	getUsing(K key, Object value)
void	keysFor(int segment, SubscriptionConsumer<K> kConsumer)
long	longSize()
protected void	performClose()
boolean	put(K key, V value) put an entry
boolean	remove(K key) remove a key
@Nullable KeyValueStore<K,V>	underlying()

Methods inherited from class net.openhft.chronicle.core.io.SimpleCloseable

close, isClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.chronicle.datagrid.map.KeyValueStore

containsKey, entrySetIterator, get, isKeyType, isReadOnly, keySetIterator, putIfAbsent, removeIfEqual, replace, replaceIfEqual, segmentFor, segments, valuesIterator

Methods inherited from interface net.openhft.chronicle.core.io.Closeable

close, closeQuietly, closeQuietly, notifyClosing, warnAndCloseIfNotClosed

Methods inherited from interface net.openhft.chronicle.core.io.QueryCloseable

isClosed, isClosing, throwExceptionIfClosed

Methods inherited from interface software.chronicle.datagrid.tree.KeyedView

keyedView

Methods inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

referenceId, referenceName, temporary

Methods inherited from interface net.openhft.chronicle.core.io.ManagedCloseable

createdHere, throwExceptionIfClosed, warnAndCloseIfNotClosed

Constructor Detail

FilePerKeyValueStoreBackedKeyValueStore

public FilePerKeyValueStoreBackedKeyValueStore(FilePerKeyValueStore filePerKeyValueStore,
                                               Function<K,String> keyToString,
                                               Function<V,net.openhft.chronicle.bytes.BytesStore> valueToBytesStore,
                                               Function<net.openhft.chronicle.bytes.BytesStore,V> bytesStoreToValue)

Method Detail

put

public boolean put(K key,
                   V value)

Description copied from interface: KeyValueStore

put an entry

Specified by:

put in interface KeyValueStore<K,V>

Parameters:

key - to set

value - to set

Returns:

true if it was replaced or the value is identical, false if it was added.

getAndPut

@Nullable
public V getAndPut(K key,
                             V value)

Specified by:

getAndPut in interface KeyValueStore<K,V>

remove

public boolean remove(K key)

Description copied from interface: KeyValueStore

remove a key

Specified by:

remove in interface KeyValueStore<K,V>

Parameters:

key - to remove

Returns:

true if it was removed, false if not.

getAndRemove

@Nullable
public V getAndRemove(K key)

Specified by:

getAndRemove in interface KeyValueStore<K,V>

getUsing

@Nullable
public V getUsing(K key,
                            Object value)

Specified by:

getUsing in interface KeyValueStore<K,V>

longSize

public long longSize()

Specified by:

longSize in interface KeyValueStore<K,V>

keysFor

public void keysFor(int segment,
                    SubscriptionConsumer<K> kConsumer)
             throws InvalidSubscriberException

Specified by:

keysFor in interface KeyValueStore<K,V>

Throws:

InvalidSubscriberException

entriesFor

public void entriesFor(int segment,
                       SubscriptionConsumer<MapEvent<K,V>> kvConsumer)
                throws InvalidSubscriberException

Specified by:

entriesFor in interface KeyValueStore<K,V>

Throws:

InvalidSubscriberException

clear

public void clear()

Specified by:

clear in interface KeyValueStore<K,V>

containsValue

public boolean containsValue(V value)

Specified by:

containsValue in interface KeyValueStore<K,V>

asset

@NotNull
public @NotNull Asset asset()

Specified by:

asset in interface Assetted<KeyValueStore<K,V>>

Returns:

The Asset this resource is associated with.

underlying

@Nullable
public @Nullable KeyValueStore<K,V> underlying()

Specified by:

underlying in interface Assetted<KeyValueStore<K,V>>

Returns:

The Underlying view this view is built on.

performClose

protected void performClose()

Overrides:

performClose in class net.openhft.chronicle.core.io.SimpleCloseable