Uses of Interface
org.apache.storm.trident.operation.Consumer

Packages that use Consumer

Package	Description
org.apache.storm.trident
org.apache.storm.trident.operation.impl

Uses of Consumer in org.apache.storm.trident

Methods in org.apache.storm.trident with parameters of type Consumer

Modifier and Type	Method and Description
Stream	Stream.peek(Consumer action) Returns a stream consisting of the trident tuples of this stream, additionally performing the provided action on each trident tuple as they are consumed from the resulting stream.

Uses of Consumer in org.apache.storm.trident.operation.impl

Constructors in org.apache.storm.trident.operation.impl with parameters of type Consumer

Constructor and Description
ConsumerExecutor(Consumer consumer)