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

    All Methods Instance Methods Abstract Methods
    Modifier and Type | Method and Description
    --- | ---
    `int[]` | `createAssignment(List<Integer> targetTasks, byte[] key)`

- - ### Method Detail

    - #### createAssignment

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

Copyright © 2021 The Apache Software Foundation. All rights reserved.