Uses of Interface
org.apache.storm.streams.operations.Consumer
-
Packages that use Consumer Package Description org.apache.storm.streams org.apache.storm.streams.operations org.apache.storm.streams.processors -
-
Uses of Consumer in org.apache.storm.streams
Methods in org.apache.storm.streams with parameters of type Consumer Modifier and Type Method Description voidStream. forEach(Consumer<? super T> action)Performs an action for each element of this stream.PairStream<K,V>PairStream. peek(Consumer<? super Pair<K,V>> action)Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as they are consumed from the resulting stream.Stream<T>Stream. peek(Consumer<? super T> action)Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as they are consumed from the resulting stream. -
Uses of Consumer in org.apache.storm.streams.operations
Classes in org.apache.storm.streams.operations that implement Consumer Modifier and Type Class Description classPrintConsumer<T>A consumer that prints the input to stdout. -
Uses of Consumer in org.apache.storm.streams.processors
Constructors in org.apache.storm.streams.processors with parameters of type Consumer Constructor Description ForEachProcessor(Consumer<T> consumer)PeekProcessor(Consumer<T> consumer)
-