storm.trident.operation.builtin
Class MapGet

java.lang.Object
  extended by storm.trident.operation.BaseOperation
      extended by storm.trident.state.BaseQueryFunction<ReadOnlyMapState,java.lang.Object>
          extended by storm.trident.operation.builtin.MapGet
All Implemented Interfaces:
java.io.Serializable, EachOperation, Operation, QueryFunction<ReadOnlyMapState,java.lang.Object>

public class MapGet
extends BaseQueryFunction<ReadOnlyMapState,java.lang.Object>

See Also:
Serialized Form

Constructor Summary
MapGet()
           
 
Method Summary
 java.util.List<java.lang.Object> batchRetrieve(ReadOnlyMapState map, java.util.List<TridentTuple> keys)
           
 void execute(TridentTuple tuple, java.lang.Object result, TridentCollector collector)
           
 
Methods inherited from class storm.trident.operation.BaseOperation
cleanup, prepare
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface storm.trident.operation.Operation
cleanup, prepare
 

Constructor Detail

MapGet

public MapGet()
Method Detail

batchRetrieve

public java.util.List<java.lang.Object> batchRetrieve(ReadOnlyMapState map,
                                                      java.util.List<TridentTuple> keys)

execute

public void execute(TridentTuple tuple,
                    java.lang.Object result,
                    TridentCollector collector)