Class | Description |
---|---|
FtpsStateForRestore |
Result object from
PointInTimeTierPartitionStateBuilder.buildFtpsFromSnapshot(java.util.Map<org.apache.kafka.common.TopicPartition, kafka.restore.db.PartitionRestoreContext>)
It will be passed in FiniteStateMachine for providing necessary info during restore. |
PointInTimeTierPartitionStateBuilder |
This class is designed for building multiple point-in-time Tier Partition States in parallel.
|
PointInTimeTierPartitionStateBuilder.FtpsSnapshotsMetadata |
Result tuple for fetchTierPartitionStateMetadata
|
SnapshotObjectStoreUtils | |
TierRecordsIterator |
This class is an iterator over a flattened stream of tier records (as
ConsumerRecord<byte[], byte[]> ) from a
list of Tier Topic Snapshots that are being downloaded. |
TierTopicConsumerForRestore |
This class is a consumer that reads from the tier state topic for restore workflow.
|