Class GraphGrouper

java.lang.Object
org.apache.storm.trident.graph.GraphGrouper

public class GraphGrouper extends Object
  • Constructor Details

  • 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)