public class CuratorDruidNodeDiscoveryProvider extends DruidNodeDiscoveryProvider
ALL_NODE_TYPES, NODE_TYPE_BROKER, NODE_TYPE_COORDINATOR, NODE_TYPE_HISTORICAL, NODE_TYPE_MM, NODE_TYPE_OVERLORD, NODE_TYPE_PEON, NODE_TYPE_ROUTER
Constructor and Description |
---|
CuratorDruidNodeDiscoveryProvider(org.apache.curator.framework.CuratorFramework curatorFramework,
ZkPathsConfig config,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and Description |
---|---|
DruidNodeDiscovery |
getForNodeType(String nodeType)
Get DruidNodeDiscovery instance to discover nodes of given nodeType.
|
void |
start() |
void |
stop() |
getForService
@Inject public CuratorDruidNodeDiscoveryProvider(org.apache.curator.framework.CuratorFramework curatorFramework, ZkPathsConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
public DruidNodeDiscovery getForNodeType(String nodeType)
DruidNodeDiscoveryProvider
getForNodeType
in class DruidNodeDiscoveryProvider
public void start()
public void stop()
Copyright © 2011–2018. All rights reserved.