Interface WorkerHelper

    • Method Detail

      • calculateRanges

        java.util.Map<java.lang.Integer,​WorkerStateGateway.WorkerRange> calculateRanges​(java.util.List<WorkerStateGateway.WorkerState> activeWorkers,
                                                                                              int rangeStart,
                                                                                              int rangeEnd)
        Calculates ranges for workers depending on the exclusiveness setting
        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