MCPcopy Create free account
hub / github.com/apache/storm / setParallelism

Method setParallelism

storm-client/src/jvm/org/apache/storm/streams/Node.java:102–104  ·  view source on GitHub ↗
(int parallelism)

Source from the content-addressed store, hash-verified

100 }
101
102 void setParallelism(int parallelism) {
103 this.parallelism = parallelism;
104 }
105
106 void addParentStream(Node parent, String streamId) {
107 parentStreams.put(parent, streamId);

Callers 3

addSinkNodeMethod · 0.45
newStreamMethod · 0.45
addNodeMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected