public class StaticAzureBlobStoreFirehoseFactory extends PrefetchableTextFilesFirehoseFactory<AzureBlob>
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 |
---|---|
boolean |
equals(Object o) |
List<AzureBlob> |
getBlobs() |
int |
hashCode() |
protected Collection<AzureBlob> |
initObjects()
Initialize objects to be read by this firehose.
|
protected InputStream |
openObjectStream(AzureBlob object)
Open an input stream from the given object.
|
protected InputStream |
wrapObjectStream(AzureBlob 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
protected Collection<AzureBlob> initObjects()
AbstractTextFilesFirehoseFactory
AbstractTextFilesFirehoseFactory.connect(StringInputRowParser, File)
is called.initObjects
in class AbstractTextFilesFirehoseFactory<AzureBlob>
protected InputStream openObjectStream(AzureBlob object) throws IOException
AbstractTextFilesFirehoseFactory
AbstractTextFilesFirehoseFactory.wrapObjectStream(Object, InputStream)
.openObjectStream
in class AbstractTextFilesFirehoseFactory<AzureBlob>
object
- an object to be readIOException
protected InputStream wrapObjectStream(AzureBlob object, InputStream stream) throws IOException
AbstractTextFilesFirehoseFactory
wrapObjectStream
in class AbstractTextFilesFirehoseFactory<AzureBlob>
object
- an input objectstream
- a stream for the objectIOException
Copyright © 2011–2018. All rights reserved.