| Package | Description | 
|---|---|
| io.druid.indexing.kafka | |
| io.druid.segment.realtime.firehose | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
KafkaIndexTask  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
EventReceiverFirehoseFactory.EventReceiverFirehose  | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.base.Optional<ChatHandler> | 
ServiceAnnouncingChatHandlerProvider.get(String key)  | 
com.google.common.base.Optional<ChatHandler> | 
NoopChatHandlerProvider.get(String key)  | 
com.google.common.base.Optional<ChatHandler> | 
ChatHandlerProvider.get(String key)
Retrieves a chat handler. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ServiceAnnouncingChatHandlerProvider.register(String service,
        ChatHandler handler)  | 
void | 
NoopChatHandlerProvider.register(String key,
        ChatHandler handler)  | 
void | 
ChatHandlerProvider.register(String key,
        ChatHandler handler)
Registers a chat handler which provides an API for others to talk to objects in the indexing service. 
 | 
void | 
ServiceAnnouncingChatHandlerProvider.register(String service,
        ChatHandler handler,
        boolean announce)  | 
void | 
NoopChatHandlerProvider.register(String key,
        ChatHandler handler,
        boolean announce)  | 
void | 
ChatHandlerProvider.register(String key,
        ChatHandler handler,
        boolean announce)
Registers a chat handler which provides an API for others to talk to objects in the indexing service. 
 | 
Copyright © 2011–2018. All rights reserved.