Package org.apache.storm.trident.graph
Class GraphGrouper
java.lang.Object
org.apache.storm.trident.graph.GraphGrouper
-
Constructor Summary
ConstructorDescriptionGraphGrouper
(org.apache.storm.shade.org.jgrapht.DirectedGraph<Node, IndexedEdge> graph, Collection<Group> initialGroups) -
Method Summary
-
Constructor Details
-
GraphGrouper
public GraphGrouper(org.apache.storm.shade.org.jgrapht.DirectedGraph<Node, IndexedEdge> graph, Collection<Group> initialGroups)
-
-
Method Details
-
getAllGroups
-
addGroup
-
reindex
public void reindex() -
mergeFully
public void mergeFully() -
outgoingGroups
-
incomingGroups
-
nodeGroup
-