io.druid.server.coordination

Class BaseZkCoordinator

java.lang.Object

io.druid.server.coordination.BaseZkCoordinator

All Implemented Interfaces:

DataSegmentChangeHandler

Direct Known Subclasses:

BridgeZkCoordinator, ZkCoordinator

public abstract class BaseZkCoordinator
extends Object
implements DataSegmentChangeHandler

Constructor Summary

Constructors

Constructor and Description
BaseZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, ZkPathsConfig zkPaths, SegmentLoaderConfig config, DruidServerMetadata me, org.apache.curator.framework.CuratorFramework curator)

Method Summary

Methods

Modifier and Type	Method and Description
abstract DataSegmentChangeHandler	getDataSegmentChangeHandler()
com.google.common.util.concurrent.ListeningExecutorService	getLoadingExecutor()
boolean	isStarted()
abstract void	loadLocalCache()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.server.coordination.DataSegmentChangeHandler

addSegment, removeSegment

Constructor Detail

BaseZkCoordinator

public BaseZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                 ZkPathsConfig zkPaths,
                 SegmentLoaderConfig config,
                 DruidServerMetadata me,
                 org.apache.curator.framework.CuratorFramework curator)

Method Detail

start

public void start()
           throws IOException

Throws:

IOException

stop

public void stop()

isStarted

public boolean isStarted()

loadLocalCache

public abstract void loadLocalCache()

getDataSegmentChangeHandler

public abstract DataSegmentChangeHandler getDataSegmentChangeHandler()

getLoadingExecutor

public com.google.common.util.concurrent.ListeningExecutorService getLoadingExecutor()