public class PartitionedGroupDeterminer extends Object implements OutputGroupDeterminer
OutputGroupDeterminer
groups events into 'n' number of partitions. The events will
be divided into predefined number
partitions based on the value of a given field in the event. Events which are having the same value for the
partitioning field will belong the to
the same partition.Constructor and Description |
---|
PartitionedGroupDeterminer(int partitionFieldIndex,
int partitionCount) |
Modifier and Type | Method and Description |
---|---|
String |
decideGroup(Event event)
Deciding the group of a given event and returning a unique identifier to identify a group.
|
public PartitionedGroupDeterminer(int partitionFieldIndex, int partitionCount)
public String decideGroup(Event event)
decideGroup
in interface OutputGroupDeterminer
event
- Event that needs to be decided to which group it belongs toCopyright © 2021. All rights reserved.