storm.trident.operation
Interface Function

All Superinterfaces:

EachOperation, Operation, java.io.Serializable

All Known Implementing Classes:

BaseFunction, CombinerAggregatorInitImpl, FilterExecutor, Split, StringLength, TuplifyArgs

public interface Function
extends EachOperation

Method Summary

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)