K
- key typeV
- value typepublic interface KeyValueStore<K,V>
Modifier and Type | Method and Description |
---|---|
void |
fail(int partition,
String errorMessage)
Sets local error for the store with the specified error message.
|
V |
get(K key)
Returns the current value associated with key if it exists or null otherwise.
|
Map<? extends K,? extends V> |
map(String entryType) |
V |
put(K key,
V value)
Updates the entry for key with the specified value.
|
V |
remove(K key)
Removes the entry corresponding to the key if it is present in the store.
|
MetadataStoreStatus |
status(int partition)
Status of the metadata store for the specified partition
|
V put(K key, V value)
V remove(K key)
void fail(int partition, String errorMessage)
MetadataStoreStatus status(int partition)