Package org.apache.storm.streams.operations

Interface Function<T,R>

Type Parameters:
T - the type of the input to the function
R - the type of the result of the function
All Superinterfaces:
Operation, Serializable
All Known Subinterfaces:
FlatMapFunction<T,R>, PairFlatMapFunction<T,K,V>, PairFunction<T,K,V>, TupleValueMapper<T>
All Known Implementing Classes:
EvaluationCalc, EvaluationFunction, IdentityFunction, PairValueMapper, StreamInsertMapToPairFunction, StreamsScanTupleValueMapper, ValueMapper, ValuesMapper
public interface Function<T,R> extends Operation
Represents a function that accepts one argument and produces a result.

  • Method Summary

    Modifier and Type
    Method
    Description
    R
    apply(T input)
    Applies this function to the given argument.

  • Method Details

    • apply

      R apply(T input)
      Applies this function to the given argument.
      Parameters:
      input - the input to the function
      Returns:
      the function result