Package org.apache.storm.trident.graph

Class GraphGrouper

java.lang.Object

org.apache.storm.trident.graph.GraphGrouper

public class GraphGrouper
extends Object

Constructor Summary

Constructors

Constructor	Description
GraphGrouper(org.apache.storm.shade.org.jgrapht.DirectedGraph<Node,IndexedEdge> graph, Collection<Group> initialGroups)

Method Summary

Modifier and Type	Method	Description
void	addGroup(Group g)
Collection<Group>	getAllGroups()
Collection<Group>	incomingGroups(Group g)
void	mergeFully()
Group	nodeGroup(Node n)
Collection<Group>	outgoingGroups(Group g)
void	reindex()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GraphGrouper

public GraphGrouper(org.apache.storm.shade.org.jgrapht.DirectedGraph<Node,IndexedEdge> graph,
 Collection<Group> initialGroups)

Method Details

getAllGroups

public Collection<Group> getAllGroups()

addGroup

public void addGroup(Group g)

reindex

public void reindex()

mergeFully

public void mergeFully()

outgoingGroups

public Collection<Group> outgoingGroups(Group g)

incomingGroups

public Collection<Group> incomingGroups(Group g)

nodeGroup

public Group nodeGroup(Node n)