public class TimedShutoffFirehoseFactory extends Object implements FirehoseFactory<InputRowParser>
Constructor and Description |
---|
TimedShutoffFirehoseFactory(FirehoseFactory delegateFactory,
org.joda.time.DateTime shutoffTime) |
Modifier and Type | Method and Description |
---|---|
Firehose |
connect(InputRowParser parser,
File temporaryDirectory)
Initialization method that connects up the fire hose.
|
FirehoseFactory |
getDelegateFactory() |
org.joda.time.DateTime |
getShutoffTime() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect
public TimedShutoffFirehoseFactory(FirehoseFactory delegateFactory, org.joda.time.DateTime shutoffTime)
public Firehose connect(InputRowParser parser, File temporaryDirectory) throws IOException
FirehoseFactory
PrefetchableTextFilesFirehoseFactory
may use a temporary
directory to cache data in it.connect
in interface FirehoseFactory<InputRowParser>
parser
- an input row parsertemporaryDirectory
- a directory where temporary files are storedIOException
public FirehoseFactory getDelegateFactory()
public org.joda.time.DateTime getShutoffTime()
Copyright © 2011–2018. All rights reserved.