Package | Description |
---|---|
io.druid.firehose.cloudfiles |
Modifier and Type | Method and Description |
---|---|
List<CloudFilesBlob> |
StaticCloudFilesFirehoseFactory.getBlobs() |
protected Collection<CloudFilesBlob> |
StaticCloudFilesFirehoseFactory.initObjects() |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
StaticCloudFilesFirehoseFactory.openObjectStream(CloudFilesBlob object) |
protected InputStream |
StaticCloudFilesFirehoseFactory.wrapObjectStream(CloudFilesBlob object,
InputStream stream) |
Constructor and Description |
---|
StaticCloudFilesFirehoseFactory(org.jclouds.rackspace.cloudfiles.v1.CloudFilesApi cloudFilesApi,
List<CloudFilesBlob> blobs,
Long maxCacheCapacityBytes,
Long maxFetchCapacityBytes,
Long prefetchTriggerBytes,
Long fetchTimeout,
Integer maxFetchRetry) |
Copyright © 2011–2018. All rights reserved.