org.apache.samza.storage.kv

Class KeyValueStore.Extension

java.lang.Object

org.apache.samza.storage.kv.KeyValueStore.Extension

Enclosing interface:

KeyValueStore<K,V>

public static class KeyValueStore.Extension
extends java.lang.Object

Represents an extension for classes that implement KeyValueStore.

Method Summary

Modifier and Type	Method and Description
static <K,V> void	deleteAll(KeyValueStore<K,V> store, java.util.List<K> keys) Deletes the mappings for the specified keys from this key-value store (if such mappings exist).
static <K,V> java.util.Map<K,V>	getAll(KeyValueStore<K,V> store, java.util.List<K> keys) Gets the values with which the specified keys are associated.

Methods inherited from class java.lang.Object

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

Method Detail

getAll

public static <K,V> java.util.Map<K,V> getAll(KeyValueStore<K,V> store,
                                              java.util.List<K> keys)

Gets the values with which the specified keys are associated.

Type Parameters:

K - the type of keys maintained by the specified store.

V - the type of values maintained by the specified store.

Parameters:

store - the key-value store for which this operation is to be performed.

keys - the keys with which the associated values are to be fetched.

Returns:

a map of the keys that were found and their respective values.

Throws:

java.lang.NullPointerException - if the specified keys list, or any of the keys, is null.

deleteAll

public static <K,V> void deleteAll(KeyValueStore<K,V> store,
                                   java.util.List<K> keys)

Deletes the mappings for the specified keys from this key-value store (if such mappings exist).

Type Parameters:

K - the type of keys maintained by the specified store.

V - the type of values maintained by the specified store.

Parameters:

store - the key-value store for which this operation is to be performed.

keys - the keys for which the mappings are to be deleted.

Throws:

java.lang.NullPointerException - if the specified keys list, or any of the keys, is null.