Package | Description |
---|---|
io.druid.data.input | |
io.druid.firehose.cloudfiles | |
io.druid.firehose.rocketmq | |
io.druid.indexing.firehose |
Modifier and Type | Method and Description |
---|---|
Firehose |
FirehoseFactory.connect(T parser)
Initialization method that connects up the fire hose.
|
FirehoseV2 |
FirehoseFactoryV2.connect(T parser,
Object lastCommit) |
Modifier and Type | Method and Description |
---|---|
Firehose |
StaticCloudFilesFirehoseFactory.connect(StringInputRowParser stringInputRowParser) |
Modifier and Type | Method and Description |
---|---|
Firehose |
RocketMQFirehoseFactory.connect(ByteBufferInputRowParser byteBufferInputRowParser) |
Modifier and Type | Method and Description |
---|---|
Firehose |
IngestSegmentFirehoseFactory.connect(InputRowParser inputRowParser) |
Copyright © 2011–2017. All rights reserved.