Package | Description |
---|---|
io.druid.data.input.impl | |
io.druid.firehose.azure | |
io.druid.firehose.cloudfiles | |
io.druid.firehose.google | |
io.druid.firehose.s3 | |
io.druid.segment.realtime.firehose |
Modifier and Type | Method and Description |
---|---|
StringInputRowParser |
StringInputRowParser.withParseSpec(ParseSpec parseSpec) |
Constructor and Description |
---|
FileIteratingFirehose(Iterator<org.apache.commons.io.LineIterator> lineIterators,
StringInputRowParser parser) |
Modifier and Type | Method and Description |
---|---|
Firehose |
StaticAzureBlobStoreFirehoseFactory.connect(StringInputRowParser stringInputRowParser) |
Modifier and Type | Method and Description |
---|---|
Firehose |
StaticCloudFilesFirehoseFactory.connect(StringInputRowParser stringInputRowParser) |
Modifier and Type | Method and Description |
---|---|
Firehose |
StaticGoogleBlobStoreFirehoseFactory.connect(StringInputRowParser stringInputRowParser) |
Modifier and Type | Method and Description |
---|---|
Firehose |
StaticS3FirehoseFactory.connect(StringInputRowParser firehoseParser) |
Modifier and Type | Method and Description |
---|---|
StringInputRowParser |
LocalFirehoseFactory.getParser() |
Modifier and Type | Method and Description |
---|---|
Firehose |
LocalFirehoseFactory.connect(StringInputRowParser firehoseParser) |
Constructor and Description |
---|
LocalFirehoseFactory(File baseDir,
String filter,
StringInputRowParser parser) |
Copyright © 2011–2017. All rights reserved.