Package ds.granules.streaming.core.partition.scheme

Class Summary

Class	Description
FieldPartitioner	Partitioner implementation for partitioning based on a key.
SendToAllPartitioner	Replicates the stream across to all the recipients.
SendToOnePartitioner	Send traffic to a single recipient at all times.
SendToRandomPartitioner	Partition the stream data items randomly across all recipients.