Package org.apache.storm.grouping

Interface PartialKeyGrouping.TargetSelector

All Superinterfaces:
Serializable
All Known Implementing Classes:
PartialKeyGrouping.BalancedTargetSelector
Enclosing class:
PartialKeyGrouping
public static interface PartialKeyGrouping.TargetSelector extends Serializable
This interface chooses one element from a task assignment to send a specific Tuple to.

  • Method Summary

    Modifier and Type
    Method
    Description
    Integer
    chooseTask(int[] assignedTasks)
     

  • Method Details

    • chooseTask

      Integer chooseTask(int[] assignedTasks)