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, 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)
boolean	equals(Object o)
List<URI>	getUris()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

StaticS3FirehoseFactory

public StaticS3FirehoseFactory(org.jets3t.service.impl.rest.httpclient.RestS3Service s3Client,
                       List<URI> uris)

Method Detail

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

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object