Package org.apache.storm.grouping
package org.apache.storm.grouping
-
ClassDescriptionRepresents the load that a Bolt is currently under to help in deciding where to route a tuple, to help balance the load.Holds a list of the current loads.A variation on FieldGrouping.This interface is responsible for choosing a subset of the target tasks to use for a given key.A basic implementation of target selection.This implementation of AssignmentCreator chooses two arbitrary tasks.This interface chooses one element from a task assignment to send a specific Tuple to.