io.druid.server.router

Class TieredBrokerHostSelector<T>

java.lang.Object

io.druid.server.router.TieredBrokerHostSelector<T>

public class TieredBrokerHostSelector<T>
extends Object

Constructor Summary

Constructors

Constructor and Description
TieredBrokerHostSelector(CoordinatorRuleManager ruleManager, TieredBrokerConfig tierConfig, DruidNodeDiscoveryProvider druidNodeDiscoveryProvider, List<TieredBrokerSelectorStrategy> strategies)

Method Summary

Modifier and Type	Method and Description
Map<String,List<Server>>	getAllBrokers()
Pair<String,Server>	getDefaultLookup()
String	getDefaultServiceName()
Pair<String,Server>	select(Query<T> query)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

TieredBrokerHostSelector

@Inject
public TieredBrokerHostSelector(CoordinatorRuleManager ruleManager,
                                        TieredBrokerConfig tierConfig,
                                        DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
                                        List<TieredBrokerSelectorStrategy> strategies)

Method Detail

start

public void start()

stop

public void stop()

getDefaultServiceName

public String getDefaultServiceName()

select

public Pair<String,Server> select(Query<T> query)

getDefaultLookup

public Pair<String,Server> getDefaultLookup()

getAllBrokers

public Map<String,List<Server>> getAllBrokers()