io.druid.firehose.s3

Class StaticS3FirehoseFactory

java.lang.Object

io.druid.firehose.s3.StaticS3FirehoseFactory

All Implemented Interfaces:

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

public class StaticS3FirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>

Builds firehoses that read from a predefined list of S3 objects and then dry up.

Constructor Summary

Constructors

Constructor and Description
StaticS3FirehoseFactory(org.jets3t.service.impl.rest.httpclient.RestS3Service s3Client, io.druid.data.input.impl.StringInputRowParser parser, List<URI> uris)

Method Summary

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect(io.druid.data.input.impl.StringInputRowParser firehoseParser)
io.druid.data.input.impl.StringInputRowParser	getParser()
List<URI>	getUris()

Methods inherited from class java.lang.Object

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

Constructor Detail

StaticS3FirehoseFactory

public StaticS3FirehoseFactory(org.jets3t.service.impl.rest.httpclient.RestS3Service s3Client,
                       io.druid.data.input.impl.StringInputRowParser parser,
                       List<URI> uris)

Method Detail

getParser

public io.druid.data.input.impl.StringInputRowParser getParser()

Specified by:

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

getUris

public List<URI> getUris()

connect

public io.druid.data.input.Firehose connect(io.druid.data.input.impl.StringInputRowParser firehoseParser)
                                     throws IOException

Specified by:

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

Throws:

IOException