io.druid.storage.azure

Class AzureStorage

java.lang.Object

io.druid.storage.azure.AzureStorage

public class AzureStorage
extends Object

Constructor Summary

Constructors

Constructor and Description
AzureStorage(com.microsoft.azure.storage.blob.CloudBlobClient cloudBlobClient)

Method Summary

Modifier and Type	Method and Description
List<String>	emptyCloudBlobDirectory(String containerName, String virtualDirPath)
boolean	getBlobExists(String container, String blobPath)
InputStream	getBlobInputStream(String containerName, String blobPath)
long	getBlobLength(String containerName, String blobPath)
com.microsoft.azure.storage.blob.CloudBlobContainer	getCloudBlobContainer(String containerName)
void	uploadBlob(File file, String containerName, String blobPath, boolean replaceExisting)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AzureStorage

public AzureStorage(com.microsoft.azure.storage.blob.CloudBlobClient cloudBlobClient)

Method Detail

getCloudBlobContainer

public com.microsoft.azure.storage.blob.CloudBlobContainer getCloudBlobContainer(String containerName)
                                                                          throws com.microsoft.azure.storage.StorageException,
                                                                                 URISyntaxException

Throws:

com.microsoft.azure.storage.StorageException

URISyntaxException

emptyCloudBlobDirectory

public List<String> emptyCloudBlobDirectory(String containerName,
                                            String virtualDirPath)
                                     throws com.microsoft.azure.storage.StorageException,
                                            URISyntaxException

Throws:

com.microsoft.azure.storage.StorageException

URISyntaxException

uploadBlob

public void uploadBlob(File file,
                       String containerName,
                       String blobPath,
                       boolean replaceExisting)
                throws IOException,
                       com.microsoft.azure.storage.StorageException,
                       URISyntaxException

Throws:

IOException

com.microsoft.azure.storage.StorageException

URISyntaxException

getBlobLength

public long getBlobLength(String containerName,
                          String blobPath)
                   throws URISyntaxException,
                          com.microsoft.azure.storage.StorageException

Throws:

URISyntaxException

com.microsoft.azure.storage.StorageException

getBlobInputStream

public InputStream getBlobInputStream(String containerName,
                                      String blobPath)
                               throws URISyntaxException,
                                      com.microsoft.azure.storage.StorageException

Throws:

URISyntaxException

com.microsoft.azure.storage.StorageException

getBlobExists

public boolean getBlobExists(String container,
                             String blobPath)
                      throws URISyntaxException,
                             com.microsoft.azure.storage.StorageException

Throws:

URISyntaxException

com.microsoft.azure.storage.StorageException