io.druid.server.lookup.cache

Class LookupCoordinatorManager

java.lang.Object

io.druid.server.lookup.cache.LookupCoordinatorManager

public class LookupCoordinatorManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LookupCoordinatorManager.LookupsCommunicator

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOOKUP_CONFIG_KEY
static String	LOOKUP_LISTEN_ANNOUNCE_KEY
static String	OLD_LOOKUP_CONFIG_KEY

Constructor Summary

Constructors

Constructor and Description
LookupCoordinatorManager(HttpClient httpClient, DruidNodeDiscoveryProvider druidNodeDiscoveryProvider, com.fasterxml.jackson.databind.ObjectMapper smileMapper, JacksonConfigManager configManager, LookupCoordinatorManagerConfig lookupCoordinatorManagerConfig)

Method Summary

Modifier and Type	Method and Description
boolean	deleteLookup(String tier, String lookup, AuditInfo auditInfo)
Collection<com.google.common.net.HostAndPort>	discoverNodesInTier(String tier)
Set<String>	discoverTiers()
Map<String,Map<String,LookupExtractorFactoryMapContainer>>	getKnownLookups()
Map<com.google.common.net.HostAndPort,LookupsState<LookupExtractorFactoryMapContainer>>	getLastKnownLookupsStateOnNodes()
LookupExtractorFactoryMapContainer	getLookup(String tier, String lookupName) Try to find a lookupName spec for the specified lookupName.
void	start()
void	stop()
boolean	updateLookup(String tier, String lookupName, LookupExtractorFactoryMapContainer spec, AuditInfo auditInfo)
boolean	updateLookups(Map<String,Map<String,LookupExtractorFactoryMapContainer>> updateSpec, AuditInfo auditInfo)

Methods inherited from class java.lang.Object

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

Field Detail

OLD_LOOKUP_CONFIG_KEY

public static final String OLD_LOOKUP_CONFIG_KEY

See Also:

Constant Field Values

LOOKUP_CONFIG_KEY

public static final String LOOKUP_CONFIG_KEY

See Also:

Constant Field Values

LOOKUP_LISTEN_ANNOUNCE_KEY

public static final String LOOKUP_LISTEN_ANNOUNCE_KEY

See Also:

Constant Field Values

Constructor Detail

LookupCoordinatorManager

@Inject
public LookupCoordinatorManager(HttpClient httpClient,
                                        DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
                                        com.fasterxml.jackson.databind.ObjectMapper smileMapper,
                                        JacksonConfigManager configManager,
                                        LookupCoordinatorManagerConfig lookupCoordinatorManagerConfig)

Method Detail

updateLookup

public boolean updateLookup(String tier,
                            String lookupName,
                            LookupExtractorFactoryMapContainer spec,
                            AuditInfo auditInfo)

updateLookups

public boolean updateLookups(Map<String,Map<String,LookupExtractorFactoryMapContainer>> updateSpec,
                             AuditInfo auditInfo)

getKnownLookups

public Map<String,Map<String,LookupExtractorFactoryMapContainer>> getKnownLookups()

deleteLookup

public boolean deleteLookup(String tier,
                            String lookup,
                            AuditInfo auditInfo)

discoverTiers

public Set<String> discoverTiers()

discoverNodesInTier

public Collection<com.google.common.net.HostAndPort> discoverNodesInTier(String tier)

getLastKnownLookupsStateOnNodes

public Map<com.google.common.net.HostAndPort,LookupsState<LookupExtractorFactoryMapContainer>> getLastKnownLookupsStateOnNodes()

getLookup

@Nullable
public LookupExtractorFactoryMapContainer getLookup(String tier,
                                                              String lookupName)

Try to find a lookupName spec for the specified lookupName.

Parameters:

lookupName - The lookupName to look for

Returns:

The lookupName spec if found or null if not found or if no lookups at all are found

start

public void start()

stop

public void stop()