Package org.apache.storm.starter.trident

Class DebugMemoryMapState<T>

java.lang.Object

org.apache.storm.trident.testing.MemoryMapState<T>

org.apache.storm.starter.trident.DebugMemoryMapState<T>

All Implemented Interfaces:

ITupleCollection, MapState<T>, ReadOnlyMapState<T>, RemovableMapState<T>, ReadOnlySnapshottable<T>, Snapshottable<T>, State

public class DebugMemoryMapState<T>
extends MemoryMapState<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DebugMemoryMapState.Factory

Constructor Summary

Constructors

Constructor	Description
DebugMemoryMapState(String id)

Method Summary

Modifier and Type	Method	Description
List<T>	multiUpdate(List<List<Object>> keys, List<ValueUpdater> updaters)

Methods inherited from class org.apache.storm.trident.testing.MemoryMapState

beginCommit, commit, get, getTuples, multiGet, multiPut, multiRemove, set, update

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DebugMemoryMapState

public DebugMemoryMapState(String id)

Method Detail

multiUpdate

public List<T> multiUpdate(List<List<Object>> keys,
                           List<ValueUpdater> updaters)

Specified by:

multiUpdate in interface MapState<T>

Overrides:

multiUpdate in class MemoryMapState<T>