Interface FlatMapFunction
-
- All Superinterfaces:
Serializable
- All Known Subinterfaces:
OperationAwareFlatMapFunction
public interface FlatMapFunction extends Serializable
A one to many transformation function.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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
-
-