Interface | Description |
---|---|
CustomStreamGrouping | |
LoadAwareCustomStreamGrouping | |
PartialKeyGrouping.AssignmentCreator |
This interface is responsible for choosing a subset of the target tasks to use for a given key.
|
PartialKeyGrouping.TargetSelector |
This interface chooses one element from a task assignment to send a specific Tuple to.
|
Class | Description |
---|---|
Load |
Represents the load that a Bolt is currently under to help in deciding where to route a tuple, to help balance the load.
|
LoadAwareShuffleGrouping | |
LoadMapping |
Holds a list of the current loads.
|
PartialKeyGrouping |
A variation on FieldGrouping.
|
PartialKeyGrouping.BalancedTargetSelector |
A basic implementation of target selection.
|
PartialKeyGrouping.RandomTwoTaskAssignmentCreator |
This implementation of AssignmentCreator chooses two arbitrary tasks.
|
ShuffleGrouping |
Copyright © 2022 The Apache Software Foundation. All rights reserved.