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:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RandomTwoTaskAssignmentCreator()

Method Summary

Modifier and Type	Method	Description
int[]	createAssignment(List<Integer> tasks, byte[] key)	Creates a two task assignment by selecting random tasks.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RandomTwoTaskAssignmentCreator

public RandomTwoTaskAssignmentCreator()

Method Details

createAssignment

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

Creates a two task assignment by selecting random tasks.

Specified by:

createAssignment in interface PartialKeyGrouping.AssignmentCreator