public class StaticAzureBlobStoreFirehoseFactory extends Object implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>
Constructor and Description |
---|
StaticAzureBlobStoreFirehoseFactory(AzureStorage azureStorage,
AzureBlob[] blobs) |
Modifier and Type | Method and Description |
---|---|
io.druid.data.input.Firehose |
connect(io.druid.data.input.impl.StringInputRowParser stringInputRowParser) |
List<AzureBlob> |
getBlobs() |
public StaticAzureBlobStoreFirehoseFactory(AzureStorage azureStorage, AzureBlob[] blobs)
public io.druid.data.input.Firehose connect(io.druid.data.input.impl.StringInputRowParser stringInputRowParser) throws IOException
connect
in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>
IOException
Copyright © 2011–2016. All rights reserved.