public class MemoryMapState<T> extends Object implements Snapshottable<T>, ITupleCollection, MapState<T>, RemovableMapState<T>
Modifier and Type | Class and Description |
---|---|
static class |
MemoryMapState.Factory |
Constructor and Description |
---|
MemoryMapState(String id) |
Modifier and Type | Method and Description |
---|---|
void |
beginCommit(Long txid) |
void |
commit(Long txid) |
T |
get() |
Iterator<List<Object>> |
getTuples() |
List<T> |
multiGet(List<List<Object>> keys) |
void |
multiPut(List<List<Object>> keys,
List<T> vals) |
void |
multiRemove(List<List<Object>> keys) |
List<T> |
multiUpdate(List<List<Object>> keys,
List<ValueUpdater> updaters) |
void |
set(T o) |
T |
update(ValueUpdater updater) |
public MemoryMapState(String id)
public T update(ValueUpdater updater)
update
in interface Snapshottable<T>
public void set(T o)
set
in interface Snapshottable<T>
public T get()
get
in interface ReadOnlySnapshottable<T>
public void beginCommit(Long txid)
beginCommit
in interface State
public Iterator<List<Object>> getTuples()
getTuples
in interface ITupleCollection
public List<T> multiUpdate(List<List<Object>> keys, List<ValueUpdater> updaters)
multiUpdate
in interface MapState<T>
public List<T> multiGet(List<List<Object>> keys)
multiGet
in interface ReadOnlyMapState<T>
public void multiRemove(List<List<Object>> keys)
multiRemove
in interface RemovableMapState<T>
Copyright © 2022 The Apache Software Foundation. All rights reserved.