public class LocalFirehoseFactory extends Object implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>
Constructor and Description |
---|
LocalFirehoseFactory(File baseDir,
String filter,
io.druid.data.input.impl.StringInputRowParser parser) |
Modifier and Type | Method and Description |
---|---|
io.druid.data.input.Firehose |
connect(io.druid.data.input.impl.StringInputRowParser firehoseParser) |
File |
getBaseDir() |
String |
getFilter() |
io.druid.data.input.impl.StringInputRowParser |
getParser() |
public File getBaseDir()
public String getFilter()
public io.druid.data.input.impl.StringInputRowParser getParser()
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.