PartialKeyGrouping.AssignmentCreator (Storm 2.7.1 API)

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 Description
  
  int[] createAssignment(List<Integer> targetTasks, byte[] key)

Method Detail

createAssignment

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