Package org.apache.storm.streams.operations

Interface Reducer<T>

  • Type Parameters:
    T - the type of the arguments and the result
    All Superinterfaces:
    BiFunction<T,​T,​T>, Operation, Serializable
    public interface Reducer<T>
extends BiFunction<T,​T,​T>
    The Reducer performs an operation on two values of the same type producing a result of the same type.

    • Method Detail

      • apply

        T apply​(T arg1,
        T arg2)
        Applies this function to the given arguments.
        Specified by:
        apply in interface BiFunction<T,​T,​T>
        Parameters:
        arg1 - the first argument
        arg2 - the second argument
        Returns:
        the result