Package org.apache.storm.trident.state

Interface QueryFunction<S extends State,T>

All Superinterfaces:

EachOperation, Operation, Serializable

All Known Implementing Classes:

AbstractRedisStateQuerier, BaseQueryFunction, JdbcQuery, MapGet, RedisClusterStateQuerier, RedisStateQuerier, SnapshotGet, TupleCollectionGet

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

Method Summary

Modifier and Type	Method	Description
List<T>	batchRetrieve(S state, List<TridentTuple> args)
void	execute(TridentTuple tuple, T result, TridentCollector collector)

Methods inherited from interface org.apache.storm.trident.operation.Operation

cleanup, prepare

Method Detail

batchRetrieve

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

execute

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