public class S3TierObjectStore extends java.lang.Object implements TierObjectStore
TierObjectStore.FileType, TierObjectStore.ObjectMetadata
Constructor and Description |
---|
S3TierObjectStore(S3TierObjectStoreConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
deleteSegment(TierObjectStore.ObjectMetadata objectMetadata) |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getObject, getObject
public S3TierObjectStore(S3TierObjectStoreConfig config)
public TierObjectStoreResponse getObject(TierObjectStore.ObjectMetadata objectMetadata, TierObjectStore.FileType fileType, java.lang.Integer byteOffsetStart, java.lang.Integer byteOffsetEnd)
getObject
in interface TierObjectStore
public 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)
putSegment
in interface TierObjectStore
public void deleteSegment(TierObjectStore.ObjectMetadata objectMetadata)
deleteSegment
in interface TierObjectStore
public void close()
close
in interface TierObjectStore