Package | Description |
---|---|
io.druid.firehose.azure | |
io.druid.storage.azure |
Constructor and Description |
---|
StaticAzureBlobStoreFirehoseFactory(AzureStorage azureStorage,
List<AzureBlob> blobs,
Long maxCacheCapacityBytes,
Long maxFetchCapacityBytes,
Long prefetchTriggerBytes,
Long fetchTimeout,
Integer maxFetchRetry) |
Modifier and Type | Method and Description |
---|---|
AzureStorage |
AzureStorageDruidModule.getAzureStorageContainer(com.microsoft.azure.storage.blob.CloudBlobClient cloudBlobClient) |
Constructor and Description |
---|
AzureByteSource(AzureStorage azureStorage,
String containerName,
String blobPath) |
AzureDataSegmentKiller(AzureStorage azureStorage) |
AzureDataSegmentPuller(AzureStorage azureStorage) |
AzureDataSegmentPusher(AzureStorage azureStorage,
AzureAccountConfig config,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
AzureTaskLogs(AzureTaskLogsConfig config,
AzureStorage azureStorage) |
Copyright © 2011–2018. All rights reserved.