Method stateQuery

storm-client/src/jvm/org/apache/storm/streams/Stream.java:366–370

Queries the given stream state with the values in this stream as the keys. @param streamState the stream state @param the value type @return the result stream

(StreamState<T, V> streamState)

     * @return the result stream
     */
    public <V> PairStream<T, V> stateQuery(StreamState<T, V> streamState) {
        // need field grouping for state query so that the query is routed to the correct task
        Node newNode = partitionBy(VALUE, node.getParallelism()).addProcessorNode(new StateQueryProcessor<>(streamState), KEY_VALUE);
        return new PairStream<>(streamBuilder, newNode);
    }

    Node getNode() {
        return node;