public class MockInMemoryTierObjectStore extends java.lang.Object implements TierObjectStore, java.lang.AutoCloseable
TierObjectStore.TierObjectStoreFileType
Constructor and Description |
---|
MockInMemoryTierObjectStore(TierObjectStoreConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
TierObjectStoreResponse |
getObject(TierObjectMetadata objectMetadata,
TierObjectStore.TierObjectStoreFileType objectFileType,
java.lang.Integer byteOffset,
java.lang.Integer byteOffsetEnd) |
java.util.concurrent.ConcurrentHashMap<java.lang.String,byte[]> |
getStored() |
TierObjectMetadata |
putSegment(TierObjectMetadata objectMetadata,
java.io.File segmentData,
java.io.File offsetIndexData,
java.io.File timestampIndexData,
java.io.File producerStateSnapshotData,
java.io.File transactionIndexData,
java.util.Optional<java.io.File> epochState) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getObject, getObject
public MockInMemoryTierObjectStore(TierObjectStoreConfig config)
public java.util.concurrent.ConcurrentHashMap<java.lang.String,byte[]> getStored()
public TierObjectStoreResponse getObject(TierObjectMetadata objectMetadata, TierObjectStore.TierObjectStoreFileType objectFileType, java.lang.Integer byteOffset, java.lang.Integer byteOffsetEnd) throws java.io.IOException
getObject
in interface TierObjectStore
java.io.IOException
public void close()
close
in interface java.lang.AutoCloseable
close
in interface TierObjectStore
public TierObjectMetadata putSegment(TierObjectMetadata objectMetadata, java.io.File segmentData, java.io.File offsetIndexData, java.io.File timestampIndexData, java.io.File producerStateSnapshotData, java.io.File transactionIndexData, java.util.Optional<java.io.File> epochState) throws java.io.IOException
putSegment
in interface TierObjectStore
java.io.IOException