org.apache.storm.trident.operation

Interface FlatMapFunction

All Superinterfaces:

Serializable

All Known Subinterfaces:

OperationAwareFlatMapFunction

All Known Implementing Classes:

EvaluationCalc

public interface FlatMapFunction
extends Serializable

A one to many transformation function

Method Summary

Modifier and Type	Method and Description
Iterable<Values>	execute(TridentTuple input) Invoked by the framework for each trident tuple in a stream.

Method Detail

execute

Iterable<Values> execute(TridentTuple input)

Invoked by the framework for each trident tuple in a stream.

Parameters:

input - the input trident tuple

Returns:

an iterable over the resultant values