Package com.continuent.tungsten.replicator.storage.parallel

Interface Summary

Partitioner	Implements an algorithm to divide replicator events into partitions.
PartitionMetadata	Denotes information describing a partition.
StatefulPartitioner	Denotes a partitioner that depends on knowledge of queue state to make partitioning decision.

Class Summary

HashPartitioner	Implements a simple shard partitioner that hashes on the shard name.
LoadBalancingPartitioner	Partitions event by assigning to the least loaded queue.
ParallelQueueApplier	Implements Applier interface for a parallel queue.
ParallelQueueExtractor	Implements ParallelExtractor interface for a parallel queue.
ParallelQueueStore	Implements an parallel event store.
PartitionerResponse	Contains partitioning response data.
PartitionerUtility	Utility functions for partitioning operations.
RoundRobinPartitioner	Partitions event by assigning each succeeding sequence number to the next partition.
ShardListPartitioner	Partitions events using a map that directs shard assignment to partition numbers.
SimplePartitioner	Implements the simplest possible partitioner, which just returns the task ID.