storm.trident.operation

Interface Function

All Superinterfaces:

EachOperation, Operation, Serializable

All Known Implementing Classes:

BaseFunction, CombinerAggregatorInitImpl, FilterExecutor, Split, StringLength, TridentReach.ExpandList, TridentWordCount.Split, TuplifyArgs

public interface Function
extends EachOperation

Method Summary

Modifier and Type	Method and Description
void	execute(TridentTuple tuple, TridentCollector collector)

Methods inherited from interface storm.trident.operation.Operation

cleanup, prepare

Method Detail

execute

void execute(TridentTuple tuple,
             TridentCollector collector)