Method peek

storm-client/src/jvm/org/apache/storm/streams/Stream.java:178–180

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. @param action the action to perform on the element as they are consumed from the stream @return the new stream

(Consumer<? super T> action)

     * @return the new stream
     */
    public Stream<T> peek(Consumer<? super T> action) {
        return new Stream<>(streamBuilder, addProcessorNode(new PeekProcessor<>(action), node.getOutputFields(), true));
    }

    /**
     * Aggregates the values in this stream using the aggregator. This does a global aggregation of values across all partitions.