Package org.apache.storm.trident.operation

Interface MapFunction

All Superinterfaces:
Serializable
All Known Subinterfaces:
OperationAwareMapFunction
public interface MapFunction extends Serializable
A one-one transformation function.

  • Method Summary

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

  • Method Details

    • execute

      Values execute(TridentTuple input)
      Invoked by the framework for each trident tuple in a stream.
      Parameters:
      input - the input trident tuple
      Returns:
      the transformed values