| Package | Description |
|---|---|
| ds.granules.streaming.core.partition | |
| ds.granules.streaming.core.partition.scheme |
| Modifier and Type | Method and Description |
|---|---|
Partitioner |
PartitionerFactory.getInstance(int type) |
| Modifier and Type | Class and Description |
|---|---|
class |
FieldPartitioner
Partitioner implementation for partitioning based on a key.
|
class |
SendToAllPartitioner
Replicates the stream across to all the recipients.
|
class |
SendToOnePartitioner
Send traffic to a single recipient at all times.
|
class |
SendToRandomPartitioner
Partition the stream data items randomly across all recipients.
|
Copyright © 2015. All rights reserved.