public class GlobalGrouping extends Object implements CustomStreamGrouping
Constructor and Description |
---|
GlobalGrouping() |
Modifier and Type | Method and Description |
---|---|
List<Integer> |
chooseTasks(int i,
List<Object> list)
This function implements a custom stream grouping.
|
void |
prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targets)
Tells the stream grouping at runtime the tasks in the target bolt.
|
public void prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targets)
CustomStreamGrouping
prepare
in interface CustomStreamGrouping
public List<Integer> chooseTasks(int i, List<Object> list)
CustomStreamGrouping
chooseTasks
in interface CustomStreamGrouping
list
- the values to group onCopyright © 2016 The Apache Software Foundation. All Rights Reserved.