Uses of Class
org.apache.storm.trident.planner.Node
Package
Description
-
Uses of Node in org.apache.storm.trident
Modifier and TypeMethodDescriptionprotected Stream
protected Stream
TridentTopology.addSourcedNode
(List<Stream> sources, Node newNode) protected Stream
TridentTopology.addSourcedNode
(Stream source, Node newNode) protected TridentState
TridentTopology.addSourcedStateNode
(List<Stream> sources, Node newNode) protected TridentState
TridentTopology.addSourcedStateNode
(Stream source, Node newNode) protected void
TridentTopology.registerNode
(Node n) protected void
TridentTopology.registerSourcedNode
(List<Stream> sources, Node newNode) ModifierConstructorDescriptionprotected
Stream
(TridentTopology topology, String name, Node node) protected
TridentState
(TridentTopology topology, Node node) -
Uses of Node in org.apache.storm.trident.graph
ModifierConstructorDescriptionModifierConstructorDescriptionGraphGrouper
(org.apache.storm.shade.org.jgrapht.DirectedGraph<Node, IndexedEdge> graph, Collection<Group> initialGroups) -
Uses of Node in org.apache.storm.trident.planner
ModifierConstructorDescriptionSubtopologyBolt
(org.apache.storm.shade.org.jgrapht.graph.DefaultDirectedGraph<Node, IndexedEdge> graph, Set<Node> nodes, Map<Node, String> batchGroups) SubtopologyBolt
(org.apache.storm.shade.org.jgrapht.graph.DefaultDirectedGraph<Node, IndexedEdge> graph, Set<Node> nodes, Map<Node, String> batchGroups) SubtopologyBolt
(org.apache.storm.shade.org.jgrapht.graph.DefaultDirectedGraph<Node, IndexedEdge> graph, Set<Node> nodes, Map<Node, String> batchGroups)