|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use PartitionerResponse | |
|---|---|
| com.continuent.tungsten.replicator.storage.parallel | |
| Uses of PartitionerResponse in com.continuent.tungsten.replicator.storage.parallel |
|---|
| Methods in com.continuent.tungsten.replicator.storage.parallel that return PartitionerResponse | |
|---|---|
PartitionerResponse |
ShardListPartitioner.partition(ReplDBMSHeader event,
int taskId)
Assign an event to a particular partition. |
PartitionerResponse |
SimplePartitioner.partition(ReplDBMSHeader event,
int taskId)
Assign an event to a particular partition. |
PartitionerResponse |
HashPartitioner.partition(ReplDBMSHeader event,
int taskId)
Assign an event to a particular partition. |
PartitionerResponse |
RoundRobinPartitioner.partition(ReplDBMSHeader event,
int taskId)
Assign an event to a particular partition. |
PartitionerResponse |
Partitioner.partition(ReplDBMSHeader event,
int taskId)
Assign an event to a particular partition. |
PartitionerResponse |
LoadBalancingPartitioner.partition(ReplDBMSHeader event,
int taskId)
Returns the partition with the smallest current size or the first partition that has a current size of zero. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||