Package | Description |
---|---|
io.druid.data.input.impl | |
io.druid.data.input.impl.prefetch | |
io.druid.segment.realtime.firehose | |
io.druid.segment.transform |
Modifier and Type | Method and Description |
---|---|
StringInputRowParser |
StringInputRowParser.withParseSpec(ParseSpec parseSpec) |
Modifier and Type | Method and Description |
---|---|
Firehose |
AbstractTextFilesFirehoseFactory.connect(StringInputRowParser firehoseParser,
File temporaryDirectory) |
Constructor and Description |
---|
FileIteratingFirehose(Iterator<org.apache.commons.io.LineIterator> lineIterators,
StringInputRowParser parser) |
FileIteratingFirehose(Iterator<org.apache.commons.io.LineIterator> lineIterators,
StringInputRowParser parser,
Closeable closer) |
Modifier and Type | Method and Description |
---|---|
Firehose |
PrefetchableTextFilesFirehoseFactory.connect(StringInputRowParser firehoseParser,
File temporaryDirectory) |
Modifier and Type | Method and Description |
---|---|
StringInputRowParser |
LocalFirehoseFactory.getParser() |
Constructor and Description |
---|
LocalFirehoseFactory(File baseDir,
String filter,
StringInputRowParser parser) |
Modifier and Type | Class and Description |
---|---|
class |
TransformingStringInputRowParser |
Modifier and Type | Method and Description |
---|---|
StringInputRowParser |
TransformingStringInputRowParser.withParseSpec(ParseSpec parseSpec) |
Copyright © 2011–2018. All rights reserved.