| Package | Description | 
|---|---|
| io.druid.indexing.kafka | |
| io.druid.segment.realtime.firehose | 
| Constructor and Description | 
|---|
KafkaIndexTask(String id,
              TaskResource taskResource,
              DataSchema dataSchema,
              KafkaTuningConfig tuningConfig,
              KafkaIOConfig ioConfig,
              Map<String,Object> context,
              ChatHandlerProvider chatHandlerProvider)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
NoopChatHandlerProvider  | 
class  | 
ServiceAnnouncingChatHandlerProvider
Provides a way for the outside world to talk to objects in the indexing service. 
 | 
| Constructor and Description | 
|---|
ChatHandlerResource(ChatHandlerProvider handlers,
                   DataSourceTaskIdHolder taskIdHolder)  | 
EventReceiverFirehoseFactory(String serviceName,
                            Integer bufferSize,
                            ChatHandlerProvider chatHandlerProvider,
                            com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                            com.fasterxml.jackson.databind.ObjectMapper smileMapper,
                            EventReceiverFirehoseRegister eventReceiverFirehoseRegister)  | 
Copyright © 2011–2017. All rights reserved.