public interface TierObjectStore
Modifier and Type | Interface and Description |
---|---|
static class |
TierObjectStore.FileType |
static class |
TierObjectStore.ObjectMetadata |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
deleteSegment(TierObjectStore.ObjectMetadata objectMetadata) |
default TierObjectStoreResponse |
getObject(TierObjectStore.ObjectMetadata objectMetadata,
TierObjectStore.FileType fileType) |
default TierObjectStoreResponse |
getObject(TierObjectStore.ObjectMetadata objectMetadata,
TierObjectStore.FileType fileType,
java.lang.Integer byteOffsetStart) |
TierObjectStoreResponse |
getObject(TierObjectStore.ObjectMetadata objectMetadata,
TierObjectStore.FileType fileType,
java.lang.Integer byteOffsetStart,
java.lang.Integer byteOffsetEnd) |
void |
putSegment(TierObjectStore.ObjectMetadata objectMetadata,
java.io.File segmentData,
java.io.File offsetIndexData,
java.io.File timestampIndexData,
java.util.Optional<java.io.File> producerStateSnapshotData,
java.util.Optional<java.nio.ByteBuffer> transactionIndexData,
java.util.Optional<java.io.File> epochState) |
TierObjectStoreResponse getObject(TierObjectStore.ObjectMetadata objectMetadata, TierObjectStore.FileType fileType, java.lang.Integer byteOffsetStart, java.lang.Integer byteOffsetEnd) throws java.io.IOException
java.io.IOException
default TierObjectStoreResponse getObject(TierObjectStore.ObjectMetadata objectMetadata, TierObjectStore.FileType fileType, java.lang.Integer byteOffsetStart) throws java.io.IOException
java.io.IOException
default TierObjectStoreResponse getObject(TierObjectStore.ObjectMetadata objectMetadata, TierObjectStore.FileType fileType) throws java.io.IOException
java.io.IOException
void putSegment(TierObjectStore.ObjectMetadata objectMetadata, java.io.File segmentData, java.io.File offsetIndexData, java.io.File timestampIndexData, java.util.Optional<java.io.File> producerStateSnapshotData, java.util.Optional<java.nio.ByteBuffer> transactionIndexData, java.util.Optional<java.io.File> epochState) throws TierObjectStoreRetriableException, java.io.IOException
TierObjectStoreRetriableException
java.io.IOException
void deleteSegment(TierObjectStore.ObjectMetadata objectMetadata) throws java.io.IOException
java.io.IOException
void close()