public interface CustomStreamGrouping
extends java.io.Serializable
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.Integer> |
chooseTasks(java.util.List<java.lang.Object> values)
This function implements a custom stream grouping.
|
void |
prepare(TopologyContext context,
java.lang.String component,
java.lang.String streamId,
java.util.List<java.lang.Integer> targetTasks)
Tells the stream grouping at runtime the tasks in the target bolt.
|
void prepare(TopologyContext context, java.lang.String component, java.lang.String streamId, java.util.List<java.lang.Integer> targetTasks)
java.util.List<java.lang.Integer> chooseTasks(java.util.List<java.lang.Object> values)
values
- the values to group on