public class LocalFirehoseFactory extends AbstractTextFilesFirehoseFactory<File>
Constructor and Description |
---|
LocalFirehoseFactory(File baseDir,
String filter,
StringInputRowParser parser) |
Modifier and Type | Method and Description |
---|---|
File |
getBaseDir() |
String |
getFilter() |
StringInputRowParser |
getParser() |
protected Collection<File> |
initObjects()
Initialize objects to be read by this firehose.
|
protected InputStream |
openObjectStream(File object)
Open an input stream from the given object.
|
protected InputStream |
wrapObjectStream(File object,
InputStream stream)
Wrap the given input stream if needed.
|
connect
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect
public LocalFirehoseFactory(File baseDir, String filter, StringInputRowParser parser)
public File getBaseDir()
public String getFilter()
public StringInputRowParser getParser()
protected Collection<File> initObjects()
AbstractTextFilesFirehoseFactory
AbstractTextFilesFirehoseFactory.connect(StringInputRowParser, File)
is called.initObjects
in class AbstractTextFilesFirehoseFactory<File>
protected InputStream openObjectStream(File object) throws IOException
AbstractTextFilesFirehoseFactory
AbstractTextFilesFirehoseFactory.wrapObjectStream(Object, InputStream)
.openObjectStream
in class AbstractTextFilesFirehoseFactory<File>
object
- an object to be readIOException
protected InputStream wrapObjectStream(File object, InputStream stream) throws IOException
AbstractTextFilesFirehoseFactory
wrapObjectStream
in class AbstractTextFilesFirehoseFactory<File>
object
- an input objectstream
- a stream for the objectIOException
Copyright © 2011–2018. All rights reserved.