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 Description StreamStream. 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 Description ConsumerExecutor(Consumer consumer)
-