public class IndexHashGrouping extends Object implements CustomStreamGrouping
Constructor and Description |
---|
IndexHashGrouping(int index) |
Modifier and Type | Method and Description |
---|---|
List<Integer> |
chooseTasks(int fromTask,
List<Object> values)
This function implements a custom stream grouping.
|
static int |
objectToIndex(Object val,
int numPartitions) |
void |
prepare(WorkerTopologyContext context,
GlobalStreamId stream,
List<Integer> targetTasks)
Tells the stream grouping at runtime the tasks in the target bolt.
|
public static int objectToIndex(Object val, int numPartitions)
public void prepare(WorkerTopologyContext context, GlobalStreamId stream, List<Integer> targetTasks)
CustomStreamGrouping
It also tells the grouping the metadata on the stream this grouping will be used on.
prepare
in interface CustomStreamGrouping
public List<Integer> chooseTasks(int fromTask, List<Object> values)
CustomStreamGrouping
chooseTasks
in interface CustomStreamGrouping
values
- the values to group onCopyright © 2023 The Apache Software Foundation. All rights reserved.