@Singleton public class AzureBlobStore extends BaseBlobStore
blobUtils, context, defaultLocation, locations, slicer
Modifier and Type | Method and Description |
---|---|
void |
abortMultipartUpload(MultipartUpload mpu) |
boolean |
blobExists(String container,
String key)
This implementation invokes
AzureBlobClient.blobExists(java.lang.String, java.lang.String) |
BlobMetadata |
blobMetadata(String container,
String key)
This implementation invokes
AzureBlobClient.getBlobProperties(java.lang.String, java.lang.String) |
String |
completeMultipartUpload(MultipartUpload mpu,
List<MultipartPart> parts) |
boolean |
containerExists(String container)
This implementation invokes
AzureBlobClient#bucketExists |
String |
copyBlob(String fromContainer,
String fromName,
String toContainer,
String toName,
CopyOptions options)
Copy blob from one container to another.
|
boolean |
createContainerInLocation(Location location,
String container)
This implementation invokes
AzureBlobClient#putBucketInRegion |
boolean |
createContainerInLocation(Location location,
String container,
CreateContainerOptions options) |
protected boolean |
deleteAndVerifyContainerGone(String container)
Delete a container if it is empty.
|
void |
deleteContainer(String container)
This implementation invokes
AzureBlobClient.deleteContainer(java.lang.String) |
Blob |
getBlob(String container,
String key,
GetOptions options)
This implementation invokes
AzureBlobClient.getBlob(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...) |
BlobAccess |
getBlobAccess(String container,
String key) |
ListBlobBlocksResponse |
getBlockList(String container,
String name)
Get Block ID List for a blob
|
ContainerAccess |
getContainerAccess(String container) |
long |
getMaximumMultipartPartSize() |
int |
getMaximumNumberOfParts() |
long |
getMinimumMultipartPartSize() |
MultipartUpload |
initiateMultipartUpload(String container,
BlobMetadata blobMetadata,
PutOptions options) |
PageSet<? extends StorageMetadata> |
list()
This implementation invokes
AzureBlobClient.listContainers(org.jclouds.azure.storage.options.ListOptions...) |
PageSet<? extends StorageMetadata> |
list(String container,
ListContainerOptions options)
This implementation invokes
AzureBlobClient.listBlobs(java.lang.String, org.jclouds.azureblob.options.ListBlobsOptions...) |
List<MultipartPart> |
listMultipartUpload(MultipartUpload mpu) |
List<MultipartUpload> |
listMultipartUploads(String container) |
String |
putBlob(String container,
Blob blob)
This implementation invokes
AzureBlobClient#putObject |
String |
putBlob(String container,
Blob blob,
PutOptions options)
This implementation invokes
AzureBlobClient#putObject |
void |
putBlock(String container,
String name,
String blockId,
Payload block)
The Put Block operation creates a block blob on Azure which can be later assembled into
a single, large blob object with the Put Block List operation.
|
String |
putBlockList(String container,
String name,
List<String> blockIdList)
The Put Block operation creates a block blob on Azure which can be later assembled into
a single, large blob object with the Put Block List operation.
|
void |
removeBlob(String container,
String key)
This implementation invokes
AzureBlobClient#deleteObject |
void |
setBlobAccess(String container,
String key,
BlobAccess access) |
void |
setContainerAccess(String container,
ContainerAccess access) |
InputStream |
streamBlob(String container,
String name) |
MultipartPart |
uploadMultipartPart(MultipartUpload mpu,
int partNumber,
Payload payload) |
blobBuilder, clearContainer, clearContainer, countBlobs, countBlobs, createDirectory, deleteContainerIfEmpty, deleteDirectory, deletePathAndEnsureGone, directoryExists, downloadBlob, downloadBlob, getBlob, getContext, list, listAssignableLocations, putMultipartBlob, putMultipartBlob, removeBlobs, streamBlob
public PageSet<? extends StorageMetadata> list()
AzureBlobClient.listContainers(org.jclouds.azure.storage.options.ListOptions...)
public boolean containerExists(String container)
AzureBlobClient#bucketExists
container
- container namepublic boolean createContainerInLocation(Location location, String container)
AzureBlobClient#putBucketInRegion
location
- currently ignoredcontainer
- container namepublic PageSet<? extends StorageMetadata> list(String container, ListContainerOptions options)
AzureBlobClient.listBlobs(java.lang.String, org.jclouds.azureblob.options.ListBlobsOptions...)
container
- container nameoptions
- size, recursion, and context of the listpublic void deleteContainer(String container)
AzureBlobClient.deleteContainer(java.lang.String)
deleteContainer
in interface BlobStore
deleteContainer
in class BaseBlobStore
container
- container namepublic boolean blobExists(String container, String key)
AzureBlobClient.blobExists(java.lang.String, java.lang.String)
container
- container namekey
- blob keypublic Blob getBlob(String container, String key, GetOptions options)
AzureBlobClient.getBlob(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
container
- container namekey
- blob keyoptions
- byte range or condition optionspublic String putBlob(String container, Blob blob)
AzureBlobClient#putObject
container
- container nameblob
- objectpublic String putBlob(String container, Blob blob, PutOptions options)
AzureBlobClient#putObject
container
- container nameblob
- objectoptions
- byte range optionspublic String copyBlob(String fromContainer, String fromName, String toContainer, String toName, CopyOptions options)
BlobStore
copyBlob
in interface BlobStore
copyBlob
in class BaseBlobStore
public void removeBlob(String container, String key)
AzureBlobClient#deleteObject
container
- container namekey
- blob keypublic void putBlock(String container, String name, String blockId, Payload block)
public String putBlockList(String container, String name, List<String> blockIdList)
public ListBlobBlocksResponse getBlockList(String container, String name)
public BlobMetadata blobMetadata(String container, String key)
AzureBlobClient.getBlobProperties(java.lang.String, java.lang.String)
container
- container namekey
- blob keyprotected boolean deleteAndVerifyContainerGone(String container)
BaseBlobStore
deleteAndVerifyContainerGone
in class BaseBlobStore
container
- what to deletepublic boolean createContainerInLocation(Location location, String container, CreateContainerOptions options)
options
- controls default access controlBlobStore.createContainerInLocation(Location,String)
public ContainerAccess getContainerAccess(String container)
public void setContainerAccess(String container, ContainerAccess access)
public BlobAccess getBlobAccess(String container, String key)
public void setBlobAccess(String container, String key, BlobAccess access)
public MultipartUpload initiateMultipartUpload(String container, BlobMetadata blobMetadata, PutOptions options)
public void abortMultipartUpload(MultipartUpload mpu)
public String completeMultipartUpload(MultipartUpload mpu, List<MultipartPart> parts)
public MultipartPart uploadMultipartPart(MultipartUpload mpu, int partNumber, Payload payload)
public List<MultipartPart> listMultipartUpload(MultipartUpload mpu)
public List<MultipartUpload> listMultipartUploads(String container)
public long getMinimumMultipartPartSize()
public long getMaximumMultipartPartSize()
public int getMaximumNumberOfParts()
public InputStream streamBlob(String container, String name)
streamBlob
in interface BlobStore
streamBlob
in class BaseBlobStore
Copyright © 2009-2016 The Apache Software Foundation. All Rights Reserved.