io.druid.server.lookup.cache

Class LookupCoordinatorManager.LookupsCommunicator

java.lang.Object

io.druid.server.lookup.cache.LookupCoordinatorManager.LookupsCommunicator

Enclosing class:

LookupCoordinatorManager

public static class LookupCoordinatorManager.LookupsCommunicator
extends Object

Constructor Summary

Constructors

Constructor and Description
LookupsCommunicator(HttpClient httpClient, LookupCoordinatorManagerConfig lookupCoordinatorManagerConfig, com.fasterxml.jackson.databind.ObjectMapper smileMapper)

Method Summary

Modifier and Type	Method and Description
LookupsState<LookupExtractorFactoryMapContainer>	getLookupStateForNode(HostAndPortWithScheme node)
LookupsState<LookupExtractorFactoryMapContainer>	updateNode(HostAndPortWithScheme node, LookupsState<LookupExtractorFactoryMapContainer> lookupsUpdate)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LookupsCommunicator

public LookupsCommunicator(HttpClient httpClient,
                           LookupCoordinatorManagerConfig lookupCoordinatorManagerConfig,
                           com.fasterxml.jackson.databind.ObjectMapper smileMapper)

Method Detail

updateNode

public LookupsState<LookupExtractorFactoryMapContainer> updateNode(HostAndPortWithScheme node,
                                                                   LookupsState<LookupExtractorFactoryMapContainer> lookupsUpdate)
                                                            throws IOException,
                                                                   InterruptedException,
                                                                   ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

getLookupStateForNode

public LookupsState<LookupExtractorFactoryMapContainer> getLookupStateForNode(HostAndPortWithScheme node)
                                                                       throws IOException,
                                                                              InterruptedException,
                                                                              ExecutionException

Throws:

IOException

InterruptedException

ExecutionException