Interface WorkerHelper

All Known Implementing Classes:
DefaultWorkerHelper

public interface WorkerHelper
  • Method Details

    • calculateRanges

      Map<Integer,WorkerStateGateway.WorkerRange> calculateRanges(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