io.druid.firehose.s3

Class StaticS3FirehoseFactory

java.lang.Object

io.druid.firehose.s3.StaticS3FirehoseFactory

All Implemented Interfaces:

FirehoseFactory<StringInputRowParser>

public class StaticS3FirehoseFactory
extends Object
implements FirehoseFactory<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

Modifier and Type	Method and Description
Firehose	connect(StringInputRowParser firehoseParser) Initialization method that connects up the fire hose.
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 Firehose connect(StringInputRowParser firehoseParser)
                 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

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object