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

Method Stream

storm-client/src/jvm/org/apache/storm/trident/Stream.java:103–107  ·  view source on GitHub ↗
(TridentTopology topology, String name, Node node)

Source from the content-addressed store, hash-verified

101 private final TridentTopology topology;
102
103 protected Stream(TridentTopology topology, String name, Node node) {
104 this.topology = topology;
105 this.node = node;
106 this.name = name;
107 }
108
109 /**
110 * Applies a label to the stream. Naming a stream will append the label to the name of the bolt(s) created by Trident and will be

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected