public class RestorePartitionOperator extends Object
Constructor and Description |
---|
RestorePartitionOperator(org.apache.kafka.common.TopicPartition topicPartition,
File stateFile,
long fromTimestamp,
String prefix) |
Modifier and Type | Method and Description |
---|---|
Map<UUID,String> |
getSegmentPathMap()
Retrieve the SegmentPath map, which contains all the segments whose state had been flipped from DELETE_COMPLETE to UPLOAD_COMPLETE.
|
Header |
header() |
int |
restore() |
int |
segmentNumberWithState(TierObjectMetadata.State state) |
SegmentState |
segmentStateByObjectID(UUID objectId) |
int |
totalSegments()
Retrieve the total number of segments in the tier partition state file
|
void |
updateSegmentState(UUID objectId,
TierObjectMetadata.State newState) |
public void updateSegmentState(UUID objectId, TierObjectMetadata.State newState) throws Exception
Exception
public Map<UUID,String> getSegmentPathMap()
public int totalSegments()
public Header header()
public SegmentState segmentStateByObjectID(UUID objectId)
public int segmentNumberWithState(TierObjectMetadata.State state)