public class StaticCloudFilesFirehoseFactory extends PrefetchableTextFilesFirehoseFactory<CloudFilesBlob>
Constructor and Description |
---|
StaticCloudFilesFirehoseFactory(org.jclouds.rackspace.cloudfiles.v1.CloudFilesApi cloudFilesApi,
List<CloudFilesBlob> blobs,
Long maxCacheCapacityBytes,
Long maxFetchCapacityBytes,
Long prefetchTriggerBytes,
Long fetchTimeout,
Integer maxFetchRetry) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
List<CloudFilesBlob> |
getBlobs() |
int |
hashCode() |
protected Collection<CloudFilesBlob> |
initObjects()
Initialize objects to be read by this firehose.
|
protected InputStream |
openObjectStream(CloudFilesBlob object)
Open an input stream from the given object.
|
protected InputStream |
wrapObjectStream(CloudFilesBlob object,
InputStream stream)
Wrap the given input stream if needed.
|
connect, getFetchTimeout, getMaxCacheCapacityBytes, getMaxFetchCapacityBytes, getMaxFetchRetry, getPrefetchTriggerBytes
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
connect
public List<CloudFilesBlob> getBlobs()
protected Collection<CloudFilesBlob> initObjects()
AbstractTextFilesFirehoseFactory
AbstractTextFilesFirehoseFactory.connect(StringInputRowParser, File)
is called.initObjects
in class AbstractTextFilesFirehoseFactory<CloudFilesBlob>
protected InputStream openObjectStream(CloudFilesBlob object) throws IOException
AbstractTextFilesFirehoseFactory
AbstractTextFilesFirehoseFactory.wrapObjectStream(Object, InputStream)
.openObjectStream
in class AbstractTextFilesFirehoseFactory<CloudFilesBlob>
object
- an object to be readIOException
protected InputStream wrapObjectStream(CloudFilesBlob object, InputStream stream) throws IOException
AbstractTextFilesFirehoseFactory
wrapObjectStream
in class AbstractTextFilesFirehoseFactory<CloudFilesBlob>
object
- an input objectstream
- a stream for the objectIOException
Copyright © 2011–2018. All rights reserved.