| 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–2018. All rights reserved.