This interface is responsible for choosing a subset of the target tasks to use for a given key.
This interface chooses one element from a task assignment to send a specific Tuple to.
Represents 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.
A basic implementation of target selection.
This implementation of AssignmentCreator chooses two arbitrary tasks.
Copyright © 2021 The Apache Software Foundation. All rights reserved.