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 and Description
GraphGrouper(org.apache.storm.shade.org.jgrapht.DirectedGraph<Node,IndexedEdge> graph, Collection<Group> initialGroups)

Method Summary

Modifier and Type	Method and 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 Detail

GraphGrouper

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

Method Detail

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)