Method partitionBy

storm-client/src/jvm/org/apache/storm/streams/Stream.java:432–436

(Fields fields, int parallelism)

    }

    protected Stream<T> partitionBy(Fields fields, int parallelism) {
        return new Stream<>(
            streamBuilder,
            addNode(node, new PartitionNode(stream, node.getOutputFields(), GroupingInfo.fields(fields)), parallelism));
    }

    private boolean shouldPartition() {
        return node.getParallelism() > 1;