Package org.apache.storm.trident.operation

Interface FlatMapFunction

All Superinterfaces:
Serializable
All Known Subinterfaces:
OperationAwareFlatMapFunction
public interface FlatMapFunction extends Serializable
A one to many transformation function.

  • Method Summary

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

  • Method Details

    • 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