io.druid.segment.realtime.firehose

Class LocalFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.LocalFirehoseFactory

All Implemented Interfaces:

io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>

public class LocalFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>

Constructor Summary

Constructors

Constructor and Description
LocalFirehoseFactory(File baseDir, String filter, io.druid.data.input.impl.StringInputRowParser parser)

Method Summary

Methods

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalFirehoseFactory

public LocalFirehoseFactory(File baseDir,
                    String filter,
                    io.druid.data.input.impl.StringInputRowParser parser)

Method Detail

getBaseDir

public File getBaseDir()

getFilter

public String getFilter()

getParser

public io.druid.data.input.impl.StringInputRowParser getParser()

Specified by:

getParser in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>

connect

public io.druid.data.input.Firehose connect(io.druid.data.input.impl.StringInputRowParser firehoseParser)
                                     throws IOException

Specified by:

connect in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.StringInputRowParser>

Throws:

IOException