Package org.apache.storm.scheduler

Interface SchedulerAssignment

    • Method Detail

      • isSlotOccupied

        boolean isSlotOccupied​(WorkerSlot slot)
        Is this slot part of this assignment or not.
        Parameters:
        slot - the slot to check.
        Returns:
        true if the slot is occupied by this assignment else false.

      • isExecutorAssigned

        boolean isExecutorAssigned​(ExecutorDetails executor)
        Is the executor assigned or not.
        Parameters:
        executor - the executor to check it if is assigned.
        Returns:
        true if it is assigned else false

      • getTopologyId

        String getTopologyId()
        Return the ID of the topology.
        Returns:
        the topology-id this assignment is for.

      • getExecutorToSlot

        Map<ExecutorDetails,​WorkerSlot> getExecutorToSlot()
        Get the map of executor to WorkerSlot.
        Returns:
        the executor -> slot map.

      • getExecutors

        Set<ExecutorDetails> getExecutors()
        Get the set of all executors.
        Returns:
        the executors covered by this assignments

      • getSlots

        Set<WorkerSlot> getSlots()
        Get the set of all slots that are a part of this.
        Returns:
        the set of all slots.

      • getSlotToExecutors

        Map<WorkerSlot,​Collection<ExecutorDetails>> getSlotToExecutors()
        Get the mapping of slot to executors on that slot.
        Returns:
        the slot to the executors assigned to that slot.

      • getScheduledResources

        Map<WorkerSlot,​WorkerResources> getScheduledResources()
        Get the slot to resource mapping.
        Returns:
        The slot to resource mapping

      • getNodeIdToTotalSharedOffHeapNodeMemory

        Map<String,​Double> getNodeIdToTotalSharedOffHeapNodeMemory()
        Get the total shared off heap node memory mapping.
        Returns:
        host to total shared off heap node memory mapping.