Package | Description |
---|---|
io.druid.server.namespace |
Modifier and Type | Method and Description |
---|---|
void |
KafkaExtractionManager.addListener(KafkaExtractionNamespace kafkaNamespace,
Map<String,String> map) |
com.google.common.base.Function<String,String> |
KafkaExtractionNamespaceFactory.build(KafkaExtractionNamespace extractionNamespace,
Map<String,String> cache) |
Callable<String> |
KafkaExtractionNamespaceFactory.getCachePopulator(KafkaExtractionNamespace extractionNamespace,
String unused,
Map<String,String> cache) |
Copyright © 2011–2015. All rights reserved.