Package | Description |
---|---|
io.druid.data.input | |
io.druid.firehose.rocketmq | |
io.druid.indexing.firehose |
Modifier and Type | Method and Description |
---|---|
default Firehose |
FirehoseFactory.connect(T parser)
Deprecated.
|
default Firehose |
FirehoseFactory.connect(T parser,
File temporaryDirectory)
Initialization method that connects up the fire hose.
|
FirehoseV2 |
FirehoseFactoryV2.connect(T parser,
Object lastCommit) |
Modifier and Type | Method and Description |
---|---|
Firehose |
RocketMQFirehoseFactory.connect(InputRowParser<ByteBuffer> byteBufferInputRowParser,
File temporaryDirectory) |
Modifier and Type | Method and Description |
---|---|
Firehose |
IngestSegmentFirehoseFactory.connect(InputRowParser inputRowParser,
File temporaryDirectory) |
Copyright © 2011–2018. All rights reserved.