Interface | Description |
---|---|
PartitionCreationListener |
To notify partition creations
|
PartitionRuntime |
Runtime class to handle partitioning.
|
Class | Description |
---|---|
PartitionRuntimeImpl |
Runtime class to handle partitioning.
|
PartitionStreamReceiver |
Specific
StreamJunction.Receiver implementation to pump events into partitions. |
StreamPartitioner |
create PartitionExecutors to be used to get partitioning key
|
Copyright © 2021. All rights reserved.