Class SnapshottableMap<T>
- java.lang.Object
-
- org.apache.storm.trident.state.map.SnapshottableMap<T>
-
- All Implemented Interfaces:
MapState<T>,ReadOnlyMapState<T>,ReadOnlySnapshottable<T>,Snapshottable<T>,State
public class SnapshottableMap<T> extends Object implements MapState<T>, Snapshottable<T>
-
-
Constructor Summary
Constructors Constructor Description SnapshottableMap(MapState<T> delegate, List<Object> snapshotKey)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidbeginCommit(Long txid)voidcommit(Long txid)Tget()List<T>multiGet(List<List<Object>> keys)voidmultiPut(List<List<Object>> keys, List<T> vals)List<T>multiUpdate(List<List<Object>> keys, List<ValueUpdater> updaters)voidset(T o)Tupdate(ValueUpdater updater)
-
-
-
Method Detail
-
multiGet
public List<T> multiGet(List<List<Object>> keys)
- Specified by:
multiGetin interfaceReadOnlyMapState<T>
-
multiUpdate
public List<T> multiUpdate(List<List<Object>> keys, List<ValueUpdater> updaters)
- Specified by:
multiUpdatein interfaceMapState<T>
-
beginCommit
public void beginCommit(Long txid)
- Specified by:
beginCommitin interfaceState
-
get
public T get()
- Specified by:
getin interfaceReadOnlySnapshottable<T>
-
update
public T update(ValueUpdater updater)
- Specified by:
updatein interfaceSnapshottable<T>
-
set
public void set(T o)
- Specified by:
setin interfaceSnapshottable<T>
-
-