public class RocketMQFirehoseFactory extends Object implements FirehoseFactory<InputRowParser<ByteBuffer>>
Constructor and Description |
---|
RocketMQFirehoseFactory(Properties consumerProps,
String consumerGroup,
List<String> feed,
String pullBatchSize) |
Modifier and Type | Method and Description |
---|---|
Firehose |
connect(InputRowParser<ByteBuffer> byteBufferInputRowParser,
File temporaryDirectory)
Initialization method that connects up the fire hose.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect
public RocketMQFirehoseFactory(Properties consumerProps, String consumerGroup, List<String> feed, String pullBatchSize)
public Firehose connect(InputRowParser<ByteBuffer> byteBufferInputRowParser, File temporaryDirectory) throws IOException, ParseException
FirehoseFactory
PrefetchableTextFilesFirehoseFactory
may use a temporary
directory to cache data in it.connect
in interface FirehoseFactory<InputRowParser<ByteBuffer>>
byteBufferInputRowParser
- an input row parsertemporaryDirectory
- a directory where temporary files are storedIOException
ParseException
Copyright © 2011–2018. All rights reserved.