public interface TierObjectStore
Modifier and Type | Interface and Description |
---|---|
static class |
TierObjectStore.Backend |
static class |
TierObjectStore.DataTypePathPrefix |
static class |
TierObjectStore.FileType |
static class |
TierObjectStore.ObjectMetadata |
static interface |
TierObjectStore.ObjectStoreMetadata |
static class |
TierObjectStore.TierStateRestoreSnapshotMetadata |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
deleteSegment(TierObjectStore.ObjectMetadata objectMetadata) |
TierObjectStore.Backend |
getBackend() |
default TierObjectStoreResponse |
getObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
TierObjectStore.FileType fileType) |
default TierObjectStoreResponse |
getObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
TierObjectStore.FileType fileType,
java.lang.Integer byteOffsetStart) |
TierObjectStoreResponse |
getObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
TierObjectStore.FileType fileType,
java.lang.Integer byteOffsetStart,
java.lang.Integer byteOffsetEnd) |
void |
putObject(TierObjectStore.ObjectStoreMetadata objectMetadata,
java.io.File file,
TierObjectStore.FileType type) |
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.nio.ByteBuffer> epochState) |
TierObjectStore.Backend getBackend()
TierObjectStoreResponse getObject(TierObjectStore.ObjectStoreMetadata objectMetadata, TierObjectStore.FileType fileType, java.lang.Integer byteOffsetStart, java.lang.Integer byteOffsetEnd) throws java.io.IOException
java.io.IOException
default TierObjectStoreResponse getObject(TierObjectStore.ObjectStoreMetadata objectMetadata, TierObjectStore.FileType fileType, java.lang.Integer byteOffsetStart) throws java.io.IOException
java.io.IOException
default TierObjectStoreResponse getObject(TierObjectStore.ObjectStoreMetadata objectMetadata, TierObjectStore.FileType fileType) throws java.io.IOException
java.io.IOException
void putObject(TierObjectStore.ObjectStoreMetadata objectMetadata, java.io.File file, TierObjectStore.FileType type) throws TierObjectStoreRetriableException, java.io.IOException
TierObjectStoreRetriableException
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.nio.ByteBuffer> epochState) throws TierObjectStoreRetriableException, java.io.IOException
TierObjectStoreRetriableException
java.io.IOException
void deleteSegment(TierObjectStore.ObjectMetadata objectMetadata) throws java.io.IOException
java.io.IOException
void close()