public static interface

GenericTaskRebalancer.RetryPolicy

org.apache.helix.task.GenericTaskRebalancer.RetryPolicy

Summary

Public Methods
abstract Map<ParticipantIdSortedSet<Integer>> reassign(JobConfig jobCfg, JobContext jobCtx, Collection<ParticipantId> instances, Map<ParticipantIdSortedSet<Integer>> origAssignment)
Adjust the assignment to allow for reassignment if a task keeps failing where it's currently assigned

Public Methods

public abstract Map<ParticipantIdSortedSet<Integer>> reassign (JobConfig jobCfg, JobContext jobCtx, Collection<ParticipantId> instances, Map<ParticipantIdSortedSet<Integer>> origAssignment)

Adjust the assignment to allow for reassignment if a task keeps failing where it's currently assigned

Parameters
jobCfg the job configuration
jobCtx the job context
instances instances that can serve tasks
origAssignment the unmodified assignment
Returns
  • the adjusted assignment