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 and Description
void	Stream.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 and Description
class	PrintConsumer<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 and Description
ForEachProcessor(Consumer<T> consumer)
PeekProcessor(Consumer<T> consumer)