io.druid.server.bridge

Class DruidClusterBridge

java.lang.Object

io.druid.server.bridge.DruidClusterBridge

public class DruidClusterBridge
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	BRIDGE_OWNER_NODE
static String	NODE_TYPE

Constructor Summary

Constructors

Constructor and Description

DruidClusterBridge(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DruidClusterBridgeConfig config, ZkPathsConfig zkPathsConfig, DruidServerMetadata druidServerMetadata, com.metamx.common.concurrent.ScheduledExecutorFactory scheduledExecutorFactory, DruidNode self, org.apache.curator.framework.CuratorFramework curator, AtomicReference<org.apache.curator.framework.recipes.leader.LeaderLatch> leaderLatch, BridgeZkCoordinator bridgeZkCoordinator, Announcer announcer, AbstractDataSegmentAnnouncer dataSegmentAnnouncer, ServerInventoryView serverInventoryView)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isLeader()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

BRIDGE_OWNER_NODE

public static final String BRIDGE_OWNER_NODE

See Also:

Constant Field Values

NODE_TYPE

public static final String NODE_TYPE

See Also:

Constant Field Values

Constructor Detail

DruidClusterBridge

@Inject
public DruidClusterBridge(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                         DruidClusterBridgeConfig config,
                         ZkPathsConfig zkPathsConfig,
                         DruidServerMetadata druidServerMetadata,
                         com.metamx.common.concurrent.ScheduledExecutorFactory scheduledExecutorFactory,
                         DruidNode self,
                         org.apache.curator.framework.CuratorFramework curator,
                         AtomicReference<org.apache.curator.framework.recipes.leader.LeaderLatch> leaderLatch,
                         BridgeZkCoordinator bridgeZkCoordinator,
                         Announcer announcer,
                         AbstractDataSegmentAnnouncer dataSegmentAnnouncer,
                         ServerInventoryView serverInventoryView)

Method Detail

isLeader

public boolean isLeader()

start

public void start()

stop

public void stop()