Uses of Interface
com.continuent.tungsten.replicator.storage.parallel.Partitioner

Packages that use Partitioner

com.continuent.tungsten.replicator.storage.parallel
com.continuent.tungsten.replicator.thl

Uses of Partitioner in com.continuent.tungsten.replicator.storage.parallel

Subinterfaces of Partitioner in com.continuent.tungsten.replicator.storage.parallel

interface

StatefulPartitioner Denotes a partitioner that depends on knowledge of queue state to make partitioning decision.

Classes in com.continuent.tungsten.replicator.storage.parallel that implement Partitioner

class	HashPartitioner Implements a simple shard partitioner that hashes on the shard name.
class	LoadBalancingPartitioner Partitions event by assigning to the least loaded queue.
class	RoundRobinPartitioner Partitions event by assigning each succeeding sequence number to the next partition.
class	ShardListPartitioner Partitions events using a map that directs shard assignment to partition numbers.
class	SimplePartitioner Implements the simplest possible partitioner, which just returns the task ID.

Methods in com.continuent.tungsten.replicator.storage.parallel that return Partitioner

Partitioner

ParallelQueueStore.getPartitioner()

Methods in com.continuent.tungsten.replicator.storage.parallel with parameters of type Partitioner

void	ParallelQueueStore.setPartitioner(Partitioner partitioner)

Uses of Partitioner in com.continuent.tungsten.replicator.thl

Methods in com.continuent.tungsten.replicator.thl that return Partitioner

Partitioner

THLParallelQueue.getPartitioner()

Methods in com.continuent.tungsten.replicator.thl with parameters of type Partitioner

void	THLParallelQueue.setPartitioner(Partitioner partitioner) Sets the instance used to assign events to partitions (channels).

Constructors in com.continuent.tungsten.replicator.thl with parameters of type Partitioner

THLParallelReadTask(int taskId, THL thl, Partitioner partitioner, AtomicCounter headSeqnoCounter, AtomicIntervalGuard<?> intervalGuard, int maxSize, int maxControlEvents, int syncInterval, com.continuent.tungsten.fsm.event.EventDispatcher dispatcher)
Instantiate a read task.