Class NonTransactionalMap<T>
- java.lang.Object
-
- org.apache.storm.trident.state.map.NonTransactionalMap<T>
-
- All Implemented Interfaces:
MapState<T>,ReadOnlyMapState<T>,State
public class NonTransactionalMap<T> extends Object implements MapState<T>
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedNonTransactionalMap(IBackingMap<T> backing)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidbeginCommit(Long txid)static <T> MapState<T>build(IBackingMap<T> backing)voidcommit(Long txid)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)
-
-
-
Constructor Detail
-
NonTransactionalMap
protected NonTransactionalMap(IBackingMap<T> backing)
-
-
Method Detail
-
build
public static <T> MapState<T> build(IBackingMap<T> backing)
-
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
-
-