Uses of Interface
org.apache.storm.streams.operations.Consumer
Package
Description
-
Uses of Consumer in org.apache.storm.streams
Modifier and TypeMethodDescriptionvoid
Performs an action for each element of this stream.PairStream<K,
V> 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.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
Modifier and TypeClassDescriptionclass
A consumer that prints the input to stdout. -
Uses of Consumer in org.apache.storm.streams.processors
ModifierConstructorDescriptionForEachProcessor
(Consumer<T> consumer) PeekProcessor
(Consumer<T> consumer)