io.druid.firehose.azure

Class StaticAzureBlobStoreFirehoseFactory

java.lang.Object

io.druid.firehose.azure.StaticAzureBlobStoreFirehoseFactory

All Implemented Interfaces:

io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>

public class StaticAzureBlobStoreFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.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

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect(io.druid.data.input.impl.StringInputRowParser stringInputRowParser)
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 io.druid.data.input.Firehose connect(io.druid.data.input.impl.StringInputRowParser stringInputRowParser)
                                     throws IOException

Specified by:

connect in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>

Throws:

IOException