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.