| Package | Description |
|---|---|
| io.druid.data.input | |
| io.druid.firehose.kafka | |
| io.druid.segment.realtime | |
| io.druid.segment.realtime.plumber |
| Modifier and Type | Method and Description |
|---|---|
FirehoseV2 |
FirehoseFactoryV2.connect(T parser,
Object lastCommit) |
| Modifier and Type | Method and Description |
|---|---|
FirehoseV2 |
KafkaEightSimpleConsumerFirehoseFactory.connect(ByteBufferInputRowParser firehoseParser,
Object lastCommit) |
| Modifier and Type | Method and Description |
|---|---|
FirehoseV2 |
FireDepartment.connect(Object metaData) |
| Modifier and Type | Method and Description |
|---|---|
static com.google.common.base.Supplier<Committer> |
Committers.supplierFromFirehoseV2(FirehoseV2 firehose) |
Copyright © 2011–2017. All rights reserved.