public class StaticS3FirehoseFactory extends Object implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>
Constructor and Description |
---|
StaticS3FirehoseFactory(org.jets3t.service.impl.rest.httpclient.RestS3Service s3Client,
List<URI> uris) |
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() |
public io.druid.data.input.Firehose connect(io.druid.data.input.impl.StringInputRowParser firehoseParser) throws IOException
connect
in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>
IOException
Copyright © 2011–2016. All rights reserved.