All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type |
Method and Description |
BucketHealthResult |
checkBucketHealth() |
void |
close() |
void |
deleteSegment(TierObjectStore.ObjectMetadata objectMetadata) |
void |
deleteVersions(List<TierObjectStore.KeyAndVersion> keys) |
TierObjectStore.Backend |
getBackend() |
default Set<TierObjectStore.FileType> |
getFileTypesPerSegment() |
default TierObjectStoreResponse |
getObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
TierObjectStore.FileType fileType) |
default TierObjectStoreResponse |
getObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
TierObjectStore.FileType fileType,
Integer byteOffsetStart) |
default TierObjectStoreResponse |
getObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
TierObjectStore.FileType fileType,
Integer byteOffsetStart,
Integer byteOffsetEnd) |
TierObjectStoreResponse |
getObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
TierObjectStore.FileType fileType,
Integer byteOffsetStart,
Integer byteOffsetEnd,
VersionInformation versionInformation) |
ByteBuffer |
getSnapshot(TierObjectStore.ObjectStoreMetadata metadata,
TierObjectStore.FileType fileType,
int estimatedBufferSize) |
Map<String,List<VersionInformation>> |
listObject(String keyPrefix,
boolean getVersionInfo) |
TierObjectAttribute |
objectExists(TierObjectStore.ObjectStoreMetadata objectStoreMetadata,
TierObjectStore.FileType type) |
TierObjectStore.OpaqueData |
prepPutSegment() |
void |
putBuffer(TierObjectStore.ObjectStoreMetadata objectMetadata,
ByteBuffer buffer,
TierObjectStore.FileType type) |
void |
putInMemorySegment(TierObjectStore.ObjectMetadata objectMetadata,
File segmentData,
File offsetIndexData,
File timestampIndexData,
Optional<ByteBuffer> producerStateSnapshotData,
Optional<ByteBuffer> transactionIndexData,
Optional<ByteBuffer> epochState) |
void |
putObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
File file,
TierObjectStore.FileType type) |
default void |
putSegment(TierObjectStore.ObjectMetadata objectMetadata,
File segmentData,
File offsetIndexData,
File timestampIndexData,
Optional<File> producerStateSnapshotData,
Optional<ByteBuffer> transactionIndexData,
Optional<ByteBuffer> epochState) |
void |
putSegment(TierObjectStore.ObjectMetadata objectMetadata,
File segmentData,
File offsetIndexData,
File timestampIndexData,
Optional<File> producerStateSnapshotData,
Optional<ByteBuffer> transactionIndexData,
Optional<ByteBuffer> epochState,
Optional<kafka.utils.Throttler> throttlerOpt) |
void |
restoreObjectByCopy(TierObjectStore.ObjectMetadata objectMetadata,
String key,
VersionInformation lastLiveVersion)
There are usually 2 ways to restore a deleted object:
- to remove the deleteMarker of the object to expose its last live version again as current version.
|