Class Group

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

public class Group extends Object
  • Field Details

    • nodes

      public final Set<Node> nodes
  • Constructor Details

    • Group

      public Group(org.apache.storm.shade.org.jgrapht.DirectedGraph graph, List<Node> nodes)
    • Group

      public Group(org.apache.storm.shade.org.jgrapht.DirectedGraph graph, Node n)
    • Group

      public Group(Group g1, Group g2)
  • Method Details

    • outgoingNodes

      public Set<Node> outgoingNodes()
    • incomingNodes

      public Set<Node> incomingNodes()
    • getSharedMemory

      public Set<SharedMemory> getSharedMemory()
      Get shared memory.
      Returns:
      the shared memory requests for the entire group
    • getResources

      public Map<String,Number> getResources(Map<String,Number> defaults)
      In case no resources are specified, returns empty map. In case differing types of resources are specified, throw. Otherwise, add all the resources for a group.
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object