storm.trident.state
Interface QueryFunction<S extends State,T>

All Superinterfaces:

EachOperation, Operation, java.io.Serializable

All Known Implementing Classes:

BaseQueryFunction, MapGet, SnapshotGet

public interface QueryFunction<S extends State,T>
extends EachOperation

Method Summary

java.util.List<T>	batchRetrieve(S state, java.util.List<TridentTuple> args)
void	execute(TridentTuple tuple, T result, TridentCollector collector)

Methods inherited from interface storm.trident.operation.Operation

cleanup, prepare

Method Detail

batchRetrieve

java.util.List<T> batchRetrieve(S state,
                                java.util.List<TridentTuple> args)

execute

void execute(TridentTuple tuple,
             T result,
             TridentCollector collector)