io.druid.firehose.azure

Class StaticAzureBlobStoreFirehoseFactory

java.lang.Object

io.druid.firehose.azure.StaticAzureBlobStoreFirehoseFactory

All Implemented Interfaces:

FirehoseFactory<StringInputRowParser>

public class StaticAzureBlobStoreFirehoseFactory
extends Object
implements FirehoseFactory<StringInputRowParser>

This class is heavily inspired by the StaticS3FirehoseFactory class in the io.druid.firehose.s3 package

Constructor Summary

Constructors

Constructor and Description
StaticAzureBlobStoreFirehoseFactory(AzureStorage azureStorage, AzureBlob[] blobs)

Method Summary

Modifier and Type	Method and Description
Firehose	connect(StringInputRowParser stringInputRowParser) Initialization method that connects up the fire hose.
List<AzureBlob>	getBlobs()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StaticAzureBlobStoreFirehoseFactory

public StaticAzureBlobStoreFirehoseFactory(AzureStorage azureStorage,
                                           AzureBlob[] blobs)

Method Detail

getBlobs

public List<AzureBlob> getBlobs()

connect

public Firehose connect(StringInputRowParser stringInputRowParser)
                 throws IOException

Description copied from interface: FirehoseFactory

Initialization method that connects up the fire hose. If this method returns successfully it should be safe to call hasMore() on the returned Firehose (which might subsequently block).

If this method returns null, then any attempt to call hasMore(), nextRow(), commit() and close() on the return value will throw a surprising NPE. Throwing IOException on connection failure or runtime exception on invalid configuration is preferred over returning null.

Specified by:

connect in interface FirehoseFactory<StringInputRowParser>

Throws:

IOException