public class RestorePartitionOperator extends Object
Constructor and Description |
---|
RestorePartitionOperator(org.apache.kafka.common.TopicPartition topicPartition,
String stateFileName,
long fromTimestamp) |
Modifier and Type | Method and Description |
---|---|
FtpsSegmentView |
operatorContext() |
Map<UUID,SegmentStateAndPath> |
restore()
Iterate all segments, flip their state from (SEGMENT_DELETE_COMPLETE || SEGMENT_DELETE_INITIATE) to SEGMENT_UPLOAD_COMPLETE
return the SegmentPath map, which contains all the segments whose state had been flipped.
|
SegmentState |
segmentStateByObjectID(UUID objectId) |
public Map<UUID,SegmentStateAndPath> restore() throws Exception
Exception
public FtpsSegmentView operatorContext()
public SegmentState segmentStateByObjectID(UUID objectId)