public class AzureBlockBlobTierObjectStore extends Object implements TierObjectStore
TierObjectStore.Backend, TierObjectStore.BackupObjectsListMetadata, TierObjectStore.DataTypePathPrefix, TierObjectStore.DurabilityAuditsOffsetMapMetadata, TierObjectStore.FileType, TierObjectStore.HealthMetadata, TierObjectStore.KeyAndVersion, TierObjectStore.LifecycleManagerStateMetadata, TierObjectStore.ObjectMetadata, TierObjectStore.ObjectStoreMetadata, TierObjectStore.OpaqueData, TierObjectStore.TierPartitionStateSnapshotMetadata, TierObjectStore.TierStateRestoreSnapshotMetadata, TierObjectStore.TierTopicSnapshotMetadata
Constructor and Description |
---|
AzureBlockBlobTierObjectStore(AzureBlockBlobTierObjectStoreConfig config) |
AzureBlockBlobTierObjectStore(AzureBlockBlobTierObjectStoreConfig config,
com.azure.storage.blob.BlobServiceClient blobServiceClient,
com.azure.storage.blob.BlobContainerClient blobContainerClient) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getObject, getObject, getObject
public AzureBlockBlobTierObjectStore(AzureBlockBlobTierObjectStoreConfig config)
public AzureBlockBlobTierObjectStore(AzureBlockBlobTierObjectStoreConfig config, com.azure.storage.blob.BlobServiceClient blobServiceClient, com.azure.storage.blob.BlobContainerClient blobContainerClient)
public TierObjectStore.Backend getBackend()
getBackend
in interface TierObjectStore
public Map<String,List<VersionInformation>> listObject(String keyPrefix, boolean getVersionInfo)
listObject
in interface TierObjectStore
public TierObjectStoreResponse getObject(TierObjectStore.ObjectStoreMetadata objectMetadata, TierObjectStore.FileType fileType, Integer byteOffsetStart, Integer byteOffsetEnd, VersionInformation versionInformation)
getObject
in interface TierObjectStore
public TierObjectStore.OpaqueData prepPutSegment() throws TierObjectStoreRetriableException, IOException
prepPutSegment
in interface TierObjectStore
TierObjectStoreRetriableException
IOException
public void putSegment(TierObjectStore.ObjectMetadata objectMetadata, File segmentData, File offsetIndexData, File timestampIndexData, Optional<File> producerStateSnapshotData, Optional<ByteBuffer> transactionIndexData, Optional<ByteBuffer> epochState)
putSegment
in interface TierObjectStore
public void putInMemorySegment(TierObjectStore.ObjectMetadata objectMetadata, File segmentData, File offsetIndexData, File timestampIndexData, Optional<ByteBuffer> producerStateSnapshotData, Optional<ByteBuffer> transactionIndexData, Optional<ByteBuffer> epochState)
putInMemorySegment
in interface TierObjectStore
public void putObject(TierObjectStore.ObjectStoreMetadata objectMetadata, File file, TierObjectStore.FileType fileType)
putObject
in interface TierObjectStore
public void putBuffer(TierObjectStore.ObjectStoreMetadata objectMetadata, ByteBuffer buffer, TierObjectStore.FileType fileType)
putBuffer
in interface TierObjectStore
public void restoreObjectByCopy(TierObjectStore.ObjectMetadata objectMetadata, String key, VersionInformation lastLiveVersion)
TierObjectStore
restoreObjectByCopy
in interface TierObjectStore
public void deleteSegment(TierObjectStore.ObjectMetadata objectMetadata)
deleteSegment
in interface TierObjectStore
public void deleteVersions(List<TierObjectStore.KeyAndVersion> keys)
deleteVersions
in interface TierObjectStore
public TierObjectAttribute objectExists(TierObjectStore.ObjectMetadata objectMetadata, TierObjectStore.FileType type) throws IOException, TierObjectStoreRetriableException
objectExists
in interface TierObjectStore
IOException
TierObjectStoreRetriableException
public BucketHealthResult checkBucketHealth()
checkBucketHealth
in interface TierObjectStore
public void close()
close
in interface TierObjectStore
public void putBuf(String key, Map<String,String> metadata, ByteBuffer buf)