Package org.apache.storm.grouping

Interface PartialKeyGrouping.AssignmentCreator

All Superinterfaces:
Serializable
All Known Implementing Classes:
PartialKeyGrouping.RandomTwoTaskAssignmentCreator
Enclosing class:
PartialKeyGrouping
public static interface PartialKeyGrouping.AssignmentCreator extends Serializable
This interface is responsible for choosing a subset of the target tasks to use for a given key.

NOTE: whatever scheme you use to create the assignment should be deterministic. This may be executed on multiple Storm Workers, thus each of them needs to come up with the same assignment for a given key.

  • Method Summary

    Modifier and Type
    Method
    Description
    int[]
    createAssignment(List<Integer> targetTasks, byte[] key)
     

  • Method Details

    • createAssignment

      int[] createAssignment(List<Integer> targetTasks, byte[] key)