ome.smuggler.core.service.file.impl

Class KeyValueFileStore<K extends util.object.Identifiable,V>

java.lang.Object

ome.smuggler.core.service.file.impl.KeyValueFileStore<K,V>

All Implemented Interfaces:

KeyValueStore<K,V>

public class KeyValueFileStore<K extends util.object.Identifiable,V>
extends java.lang.Object
implements KeyValueStore<K,V>

A KeyValueStore backed by a TaskFileStore. Each value is stored in a file and the file is keyed by the corresponding task ID. Values are (de-)serialised using provided readers/writers.

Constructor Summary

Constructors

Constructor and Description
KeyValueFileStore(TaskFileStore<K> store, SourceReader<java.io.InputStream,V> reader, SinkWriter<V,java.io.OutputStream> writer) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	modify(K key, java.util.function.Function<V,V> operation) Updates the value associated to the specified key.
void	put(K key, V value) Maps a key to a value.
void	remove(K key) Deletes the mapping identified by the specified key.

Methods inherited from class java.lang.Object

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

Methods inherited from interface ome.smuggler.core.service.file.KeyValueStore

get

Constructor Detail

KeyValueFileStore

public KeyValueFileStore(TaskFileStore<K> store,
                         SourceReader<java.io.InputStream,V> reader,
                         SinkWriter<V,java.io.OutputStream> writer)

Creates a new instance.

Parameters:

store - the file store to use to persist the key-value pairs.

reader - deserialises the input stream.

writer - serialises to the output stream.

Method Detail

put

public void put(K key,
                V value)

Description copied from interface: KeyValueStore

Maps a key to a value. If the specified key is already associated to a value, the old value will be overwritten.

Specified by:

put in interface KeyValueStore<K extends util.object.Identifiable,V>

Parameters:

key - identifies the mapping.

value - the value to store.

modify

public void modify(K key,
                   java.util.function.Function<V,V> operation)

Description copied from interface: KeyValueStore

Updates the value associated to the specified key.

Specified by:

modify in interface KeyValueStore<K extends util.object.Identifiable,V>

Parameters:

key - identifies the mapping.

operation - is given the current value, does something with it and then returns the new value.

remove

public void remove(K key)

Description copied from interface: KeyValueStore

Deletes the mapping identified by the specified key. Does nothing if no value is currently associated to the key.

Specified by:

remove in interface KeyValueStore<K extends util.object.Identifiable,V>

Parameters:

key - identifies the mapping.