io.druid.curator.discovery

Class CuratorDruidNodeDiscoveryProvider

java.lang.Object

io.druid.discovery.DruidNodeDiscoveryProvider

io.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider

public class CuratorDruidNodeDiscoveryProvider
extends DruidNodeDiscoveryProvider

Field Summary

Fields inherited from class io.druid.discovery.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 Summary

Constructors

Constructor and Description
CuratorDruidNodeDiscoveryProvider(org.apache.curator.framework.CuratorFramework curatorFramework, ZkPathsConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
DruidNodeDiscovery	getForNodeType(String nodeType) Get DruidNodeDiscovery instance to discover nodes of given nodeType.
void	start()
void	stop()

Methods inherited from class io.druid.discovery.DruidNodeDiscoveryProvider

getForService

Methods inherited from class java.lang.Object

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

Constructor Detail

CuratorDruidNodeDiscoveryProvider

@Inject
public CuratorDruidNodeDiscoveryProvider(org.apache.curator.framework.CuratorFramework curatorFramework,
                                                 ZkPathsConfig config,
                                                 com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

getForNodeType

public DruidNodeDiscovery getForNodeType(String nodeType)

Description copied from class: DruidNodeDiscoveryProvider

Get DruidNodeDiscovery instance to discover nodes of given nodeType.

Specified by:

getForNodeType in class DruidNodeDiscoveryProvider

start

public void start()

stop

public void stop()