storm.trident.state.map
Class CachedBatchReadsMap<T>
java.lang.Object
storm.trident.state.map.CachedBatchReadsMap<T>
- All Implemented Interfaces:
- MapState<T>, ReadOnlyMapState<T>, State
public class CachedBatchReadsMap<T>
- extends java.lang.Object
- implements MapState<T>
Method Summary |
void |
beginCommit(java.lang.Long txid)
|
void |
commit(java.lang.Long txid)
|
java.util.List<T> |
multiGet(java.util.List<java.util.List<java.lang.Object>> keys)
|
void |
multiPut(java.util.List<java.util.List<java.lang.Object>> keys,
java.util.List<T> vals)
|
java.util.List<T> |
multiUpdate(java.util.List<java.util.List<java.lang.Object>> keys,
java.util.List<ValueUpdater> updaters)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_delegate
public MapState<T> _delegate
CachedBatchReadsMap
public CachedBatchReadsMap(MapState<T> delegate)
multiGet
public java.util.List<T> multiGet(java.util.List<java.util.List<java.lang.Object>> keys)
- Specified by:
multiGet
in interface ReadOnlyMapState<T>
multiUpdate
public java.util.List<T> multiUpdate(java.util.List<java.util.List<java.lang.Object>> keys,
java.util.List<ValueUpdater> updaters)
- Specified by:
multiUpdate
in interface MapState<T>
multiPut
public void multiPut(java.util.List<java.util.List<java.lang.Object>> keys,
java.util.List<T> vals)
- Specified by:
multiPut
in interface MapState<T>
beginCommit
public void beginCommit(java.lang.Long txid)
- Specified by:
beginCommit
in interface State
commit
public void commit(java.lang.Long txid)
- Specified by:
commit
in interface State