Class DefaultWorkerHelper

  • All Implemented Interfaces:
    WorkerHelper

    public class DefaultWorkerHelper
    extends java.lang.Object
    implements WorkerHelper
    • Constructor Detail

      • DefaultWorkerHelper

        public DefaultWorkerHelper()
    • Method Detail

      • calculateRanges

        public java.util.Map<java.lang.Integer,​WorkerStateGateway.WorkerRange> calculateRanges​(java.util.List<WorkerStateGateway.WorkerState> activeWorkers,
                                                                                                     int rangeStart,
                                                                                                     int rangeEnd)
        Description copied from interface: WorkerHelper
        Calculates ranges for workers depending on the exclusiveness setting
        Specified by:
        calculateRanges in interface WorkerHelper
        Parameters:
        activeWorkers - the list of active workers
        rangeStart - beginning value of the range for a group of workers
        rangeEnd - ending value of the range for a group of workers
        Returns:
        map of ranges per worker node id