org.apache.druid.segment.realtime.firehose

Class LocalFirehoseFactory

java.lang.Object

org.apache.druid.data.input.impl.AbstractTextFilesFirehoseFactory<File>

org.apache.druid.segment.realtime.firehose.LocalFirehoseFactory

All Implemented Interfaces:

org.apache.druid.data.input.FiniteFirehoseFactory<org.apache.druid.data.input.impl.StringInputRowParser,File>, org.apache.druid.data.input.FirehoseFactory<org.apache.druid.data.input.impl.StringInputRowParser>

public class LocalFirehoseFactory
extends org.apache.druid.data.input.impl.AbstractTextFilesFirehoseFactory<File>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
File	getBaseDir()
String	getFilter()
org.apache.druid.data.input.impl.StringInputRowParser	getParser()
protected Collection<File>	initObjects()
protected InputStream	openObjectStream(File object)
org.apache.druid.data.input.FiniteFirehoseFactory<org.apache.druid.data.input.impl.StringInputRowParser,File>	withSplit(org.apache.druid.data.input.InputSplit<File> split)
protected InputStream	wrapObjectStream(File object, InputStream stream)

Methods inherited from class org.apache.druid.data.input.impl.AbstractTextFilesFirehoseFactory

connect, getNumSplits, getObjects, getSplits, initializeObjectsIfNeeded

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.data.input.FiniteFirehoseFactory

isSplittable

Methods inherited from interface org.apache.druid.data.input.FirehoseFactory

connect

Constructor Detail

LocalFirehoseFactory

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

Method Detail

getBaseDir

public File getBaseDir()

getFilter

public String getFilter()

getParser

public org.apache.druid.data.input.impl.StringInputRowParser getParser()

initObjects

protected Collection<File> initObjects()

Specified by:

initObjects in class org.apache.druid.data.input.impl.AbstractTextFilesFirehoseFactory<File>

openObjectStream

protected InputStream openObjectStream(File object)
                                throws IOException

Specified by:

openObjectStream in class org.apache.druid.data.input.impl.AbstractTextFilesFirehoseFactory<File>

Throws:

IOException

wrapObjectStream

protected InputStream wrapObjectStream(File object,
                                       InputStream stream)
                                throws IOException

Specified by:

wrapObjectStream in class org.apache.druid.data.input.impl.AbstractTextFilesFirehoseFactory<File>

Throws:

IOException

withSplit

public org.apache.druid.data.input.FiniteFirehoseFactory<org.apache.druid.data.input.impl.StringInputRowParser,File> withSplit(org.apache.druid.data.input.InputSplit<File> split)