Class TopologyResources

java.lang.Object
org.apache.storm.daemon.nimbus.TopologyResources

public final class TopologyResources extends Object
  • Constructor Details

    • TopologyResources

      public TopologyResources(TopologyDetails td, SchedulerAssignment assignment)
    • TopologyResources

      public TopologyResources(TopologyDetails td, Assignment assignment)
    • TopologyResources

      public TopologyResources()
    • TopologyResources

      protected TopologyResources(double requestedMemOnHeap, double requestedMemOffHeap, double requestedSharedMemOnHeap, double requestedSharedMemOffHeap, double requestedNonSharedMemOnHeap, double requestedNonSharedMemOffHeap, double requestedCpu, Map<String,Double> requestedGenericResources, double assignedMemOnHeap, double assignedMemOffHeap, double assignedSharedMemOnHeap, double assignedSharedMemOffHeap, double assignedNonSharedMemOnHeap, double assignedNonSharedMemOffHeap, double assignedCpu, Map<String,Double> assignedGenericResources)
  • Method Details

    • getRequestedMemOnHeap

      public double getRequestedMemOnHeap()
    • getRequestedMemOffHeap

      public double getRequestedMemOffHeap()
    • getRequestedCpu

      public double getRequestedCpu()
    • getAssignedMemOnHeap

      public double getAssignedMemOnHeap()
    • setAssignedMemOnHeap

      public void setAssignedMemOnHeap(double assignedMemOnHeap)
    • getAssignedMemOffHeap

      public double getAssignedMemOffHeap()
    • setAssignedMemOffHeap

      public void setAssignedMemOffHeap(double assignedMemOffHeap)
    • getAssignedCpu

      public double getAssignedCpu()
    • setAssignedCpu

      public void setAssignedCpu(double assignedCpu)
    • getAssignedSharedMemOnHeap

      public double getAssignedSharedMemOnHeap()
    • setAssignedSharedMemOnHeap

      public void setAssignedSharedMemOnHeap(double assignedSharedMemOnHeap)
    • getRequestedSharedMemOnHeap

      public double getRequestedSharedMemOnHeap()
    • getRequestedSharedMemOffHeap

      public double getRequestedSharedMemOffHeap()
    • getRequestedNonSharedMemOnHeap

      public double getRequestedNonSharedMemOnHeap()
    • getRequestedNonSharedMemOffHeap

      public double getRequestedNonSharedMemOffHeap()
    • getAssignedSharedMemOffHeap

      public double getAssignedSharedMemOffHeap()
    • setAssignedSharedMemOffHeap

      public void setAssignedSharedMemOffHeap(double assignedSharedMemOffHeap)
    • getAssignedNonSharedMemOnHeap

      public double getAssignedNonSharedMemOnHeap()
    • setAssignedNonSharedMemOnHeap

      public void setAssignedNonSharedMemOnHeap(double assignedNonSharedMemOnHeap)
    • getAssignedNonSharedMemOffHeap

      public double getAssignedNonSharedMemOffHeap()
    • setAssignedNonSharedMemOffHeap

      public void setAssignedNonSharedMemOffHeap(double assignedNonSharedMemOffHeap)
    • getAssignedGenericResources

      public Map<String,Double> getAssignedGenericResources()
    • getRequestedGenericResources

      public Map<String,Double> getRequestedGenericResources()
    • add

      Add the values in other to this and return a combined resources object.
      Parameters:
      other - the other resources to add to this
      Returns:
      the combined resources with the sum of the values in each.