public static class PartialKeyGrouping.BalancedTargetSelector extends Object implements PartialKeyGrouping.TargetSelector
A basic implementation of target selection. This strategy chooses the task within the assignment that has received the fewest Tuples overall from this instance of the grouping.
| Constructor and Description |
|---|
BalancedTargetSelector() |
| Modifier and Type | Method and Description |
|---|---|
Integer |
chooseTask(int[] assignedTasks)
Chooses one of the incoming tasks and selects the one that has been selected the fewest times so far.
|
public Integer chooseTask(int[] assignedTasks)
Chooses one of the incoming tasks and selects the one that has been selected the fewest times so far.
chooseTask in interface PartialKeyGrouping.TargetSelectorCopyright © 2021 The Apache Software Foundation. All rights reserved.