| Package | Description |
|---|---|
| io.druid.data.input | |
| io.druid.data.input.impl | |
| io.druid.data.input.protobuf | |
| io.druid.firehose.kafka | |
| io.druid.firehose.rabbitmq | |
| io.druid.firehose.rocketmq |
| Modifier and Type | Class and Description |
|---|---|
class |
AvroStreamInputRowParser |
| Modifier and Type | Method and Description |
|---|---|
ByteBufferInputRowParser |
AvroStreamInputRowParser.withParseSpec(ParseSpec parseSpec) |
ByteBufferInputRowParser |
ByteBufferInputRowParser.withParseSpec(ParseSpec parseSpec) |
| Modifier and Type | Class and Description |
|---|---|
class |
StringInputRowParser |
| Modifier and Type | Class and Description |
|---|---|
class |
ProtobufInputRowParser |
| Modifier and Type | Method and Description |
|---|---|
Firehose |
KafkaEightFirehoseFactory.connect(ByteBufferInputRowParser firehoseParser,
File temporaryDirectory) |
FirehoseV2 |
KafkaEightSimpleConsumerFirehoseFactory.connect(ByteBufferInputRowParser firehoseParser,
Object lastCommit) |
| Modifier and Type | Method and Description |
|---|---|
Firehose |
RabbitMQFirehoseFactory.connect(ByteBufferInputRowParser firehoseParser,
File temporaryDirectory) |
| Modifier and Type | Method and Description |
|---|---|
Firehose |
RocketMQFirehoseFactory.connect(ByteBufferInputRowParser byteBufferInputRowParser,
File temporaryDirectory) |
Copyright © 2011–2017. All rights reserved.