public class TridentState {

    TridentTopology _topology;

    Node _node;

    protected TridentState(TridentTopology topology, Node node) {

        _topology = topology;

        _node = node;

    }

    public Stream newValuesStream() {

        return new Stream(_topology, _node.name, _node);

    }

    public TridentState parallelismHint(int parallelism) {

        _node.parallelismHint = parallelism;

        return this;

    }

}