Uses of Package
org.apache.storm.grouping
-
Classes in org.apache.storm.grouping used by org.apache.storm.daemon Class Description CustomStreamGrouping LoadAwareCustomStreamGrouping LoadMapping Holds a list of the current loads. -
Classes in org.apache.storm.grouping used by org.apache.storm.daemon.worker Class Description LoadMapping Holds a list of the current loads. -
Classes in org.apache.storm.grouping used by org.apache.storm.drpc Class Description CustomStreamGrouping -
Classes in org.apache.storm.grouping used by org.apache.storm.executor Class Description LoadAwareCustomStreamGrouping LoadMapping Holds a list of the current loads. -
Classes in org.apache.storm.grouping used by org.apache.storm.grouping Class Description CustomStreamGrouping Load Represents the load that a Bolt is currently under to help in deciding where to route a tuple, to help balance the load.LoadAwareCustomStreamGrouping LoadMapping Holds a list of the current loads.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. -
Classes in org.apache.storm.grouping used by org.apache.storm.messaging 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. -
Classes in org.apache.storm.grouping used by org.apache.storm.messaging.netty 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. -
Classes in org.apache.storm.grouping used by org.apache.storm.testing Class Description CustomStreamGrouping -
Classes in org.apache.storm.grouping used by org.apache.storm.topology Class Description CustomStreamGrouping -
Classes in org.apache.storm.grouping used by org.apache.storm.trident Class Description CustomStreamGrouping -
Classes in org.apache.storm.grouping used by org.apache.storm.trident.partition Class Description CustomStreamGrouping