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