public static interface PartialKeyGrouping.TargetSelector extends Serializable
This interface chooses one element from a task assignment to send a specific Tuple to.
Modifier and Type | Method and Description |
---|---|
Integer |
chooseTask(int[] assignedTasks) |
Integer chooseTask(int[] assignedTasks)
Copyright © 2019 The Apache Software Foundation. All rights reserved.