Package | Description |
---|---|
io.druid.firehose.azure |
Modifier and Type | Method and Description |
---|---|
List<AzureBlob> |
StaticAzureBlobStoreFirehoseFactory.getBlobs() |
protected Collection<AzureBlob> |
StaticAzureBlobStoreFirehoseFactory.initObjects() |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
StaticAzureBlobStoreFirehoseFactory.openObjectStream(AzureBlob object) |
protected InputStream |
StaticAzureBlobStoreFirehoseFactory.wrapObjectStream(AzureBlob object,
InputStream stream) |
Constructor and Description |
---|
StaticAzureBlobStoreFirehoseFactory(AzureStorage azureStorage,
List<AzureBlob> blobs,
Long maxCacheCapacityBytes,
Long maxFetchCapacityBytes,
Long prefetchTriggerBytes,
Long fetchTimeout,
Integer maxFetchRetry) |
Copyright © 2011–2018. All rights reserved.