public interface FirehoseFactory<T extends InputRowParser>
Firehose
which is an interface holding onto the stream of incoming data.
It currently provides two methods for creating a Firehose
and their default implementations call each other
for the backward compatibility. Implementations of this interface must implement one of these methods.Modifier and Type | Method and Description |
---|---|
default Firehose |
connect(T parser)
Deprecated.
|
default Firehose |
connect(T parser,
File temporaryDirectory)
Initialization method that connects up the fire hose.
|
@Deprecated default Firehose connect(T parser) throws IOException, ParseException
parser
- an input row parserIOException
ParseException
default Firehose connect(T parser, File temporaryDirectory) throws IOException, ParseException
PrefetchableTextFilesFirehoseFactory
may use a temporary
directory to cache data in it.parser
- an input row parsertemporaryDirectory
- a directory where temporary files are storedIOException
ParseException
Copyright © 2011–2018. All rights reserved.