GraphGrouper (Storm 2.7.1 API)

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

All Methods Instance Methods Concrete Methods
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 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)
```