Class | Description |
---|---|
PulsarPartitionSplit |
A
SourceSplit implementation for a Pulsar's partition. |
PulsarPartitionSplitSerializer |
The
serializer for PulsarPartitionSplit . |
PulsarPartitionSplitState |
Pulsar partition split state.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.