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.