Uses of Interface
org.apache.storm.streams.operations.Operation
Packages that use Operation
Package
Description
-
Uses of Operation in org.apache.storm.sql.runtime.streams.functions
Classes in org.apache.storm.sql.runtime.streams.functions that implement OperationModifier and TypeClassDescriptionclassclassclassclassclass -
Uses of Operation in org.apache.storm.streams.operations
Subinterfaces of Operation in org.apache.storm.streams.operationsModifier and TypeInterfaceDescriptioninterfaceBiFunction<T,U, R> a function that accepts two arguments and produces a result.interfaceCombinerAggregator<T,A, R> Interface for aggregating values.interfaceConsumer<T>Represents an operation that accepts a single input argument and returns no result.interfaceFlatMapFunction<T,R> A function that accepts one argument and returns anIterableof elements as its result.interfaceFunction<T,R> Represents a function that accepts one argument and produces a result.interfacePairFlatMapFunction<T,K, V> interfacePairFunction<T,K, V> A function that accepts an argument and produces a key-value Pair.interfacePredicate<T>Represents a predicate (boolean-valued function) of a value.interfaceReducer<T>TheReducerperforms an operation on two values of the same type producing a result of the same type.interfaceStateUpdater<T,S> Interface for updating state.interfaceValueJoiner<V1,V2, R> An interface for joining two values to produce a result.Classes in org.apache.storm.streams.operations that implement OperationModifier and TypeClassDescriptionclassAFunctionthat returns the input argument itself as the result.classPairValueJoiner<V1,V2> AValueJoinerthat joins two values to produce aPairof the two values as the result.classA consumer that prints the input to stdout. -
Uses of Operation in org.apache.storm.streams.operations.aggregators
Classes in org.apache.storm.streams.operations.aggregators that implement Operation -
Uses of Operation in org.apache.storm.streams.operations.mappers
Subinterfaces of Operation in org.apache.storm.streams.operations.mappersModifier and TypeInterfaceDescriptioninterfaceA generic interface for mapping aTupleto typed values.Classes in org.apache.storm.streams.operations.mappers that implement OperationModifier and TypeClassDescriptionclassPairValueMapper<K,V> Extracts a typed key-value pair from a tuple.classValueMapper<T>Extracts a single typed value from a tuple.class