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

Method Stream

storm-client/src/jvm/org/apache/storm/streams/Stream.java:69–71  ·  view source on GitHub ↗
(StreamBuilder streamBuilder, Node node)

Source from the content-addressed store, hash-verified

67 protected final String stream;
68
69 Stream(StreamBuilder streamBuilder, Node node) {
70 this(streamBuilder, node, node.getOutputStreams().iterator().next());
71 }
72
73 private Stream(StreamBuilder streamBuilder, Node node, String stream) {
74 this.streamBuilder = streamBuilder;

Callers

nothing calls this directly

Calls 3

getOutputStreamsMethod · 0.80
nextMethod · 0.65
iteratorMethod · 0.45

Tested by

no test coverage detected