Method stateQuery

storm-client/src/jvm/org/apache/storm/trident/Stream.java:340–350

(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)

    }

    public Stream stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields) {
        projectionValidation(inputFields);
        String stateId = state.node.stateInfo.id;
        Node n = new ProcessorNode(topology.getUniqueStreamId(),
                name,
                TridentUtils.fieldsConcat(getOutputFields(), functionFields),
                functionFields,
                new StateQueryProcessor(stateId, inputFields, function));
        topology.colocate.get(stateId).add(n);
        return topology.addSourcedNode(this, n);
    }

    public Stream stateQuery(TridentState state, QueryFunction function, Fields functionFields) {
        return stateQuery(state, null, function, functionFields);