Package org.apache.storm.streams.operations
package org.apache.storm.streams.operations
-
ClassDescriptionBiFunction<T,
U, R> a function that accepts two arguments and produces a result.CombinerAggregator<T,A, R> Interface for aggregating values.Consumer<T>Represents an operation that accepts a single input argument and returns no result.FlatMapFunction<T,R> A function that accepts one argument and returns anIterableof elements as its result.Function<T,R> Represents a function that accepts one argument and produces a result.AFunctionthat returns the input argument itself as the result.The parent interface for any kind of streaming operation.PairFlatMapFunction<T,K, V> PairFunction<T,K, V> A function that accepts an argument and produces a key-value Pair.PairValueJoiner<V1,V2> AValueJoinerthat joins two values to produce aPairof the two values as the result.Predicate<T>Represents a predicate (boolean-valued function) of a value.A consumer that prints the input to stdout.Reducer<T>TheReducerperforms an operation on two values of the same type producing a result of the same type.StateUpdater<T,S> Interface for updating state.ValueJoiner<V1,V2, R> An interface for joining two values to produce a result.