Package org.apache.storm.grouping
Class PartialKeyGrouping.RandomTwoTaskAssignmentCreator
java.lang.Object
org.apache.storm.grouping.PartialKeyGrouping.RandomTwoTaskAssignmentCreator
- All Implemented Interfaces:
Serializable
,PartialKeyGrouping.AssignmentCreator
- Enclosing class:
- PartialKeyGrouping
public static class PartialKeyGrouping.RandomTwoTaskAssignmentCreator
extends Object
implements PartialKeyGrouping.AssignmentCreator
This implementation of AssignmentCreator chooses two arbitrary tasks.
- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionint[]
createAssignment
(List<Integer> tasks, byte[] key) Creates a two task assignment by selecting random tasks.
-
Constructor Details
-
RandomTwoTaskAssignmentCreator
public RandomTwoTaskAssignmentCreator()
-
-
Method Details
-
createAssignment
Creates a two task assignment by selecting random tasks.- Specified by:
createAssignment
in interfacePartialKeyGrouping.AssignmentCreator
-