io.druid.server.coordination

Class ZkCoordinator

java.lang.Object

io.druid.server.coordination.BaseZkCoordinator

io.druid.server.coordination.ZkCoordinator

All Implemented Interfaces:

DataSegmentChangeHandler

public class ZkCoordinator
extends BaseZkCoordinator

Constructor Summary

Constructors

Constructor and Description
ZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, SegmentLoaderConfig config, ZkPathsConfig zkPaths, DruidServerMetadata me, DataSegmentAnnouncer announcer, org.apache.curator.framework.CuratorFramework curator, ServerManager serverManager, com.metamx.common.concurrent.ScheduledExecutorFactory factory)

Method Summary

Methods

Modifier and Type	Method and Description
void	addSegment(io.druid.timeline.DataSegment segment, DataSegmentChangeCallback callback)
DataSegmentChangeHandler	getDataSegmentChangeHandler()
void	loadLocalCache()
void	removeSegment(io.druid.timeline.DataSegment segment, DataSegmentChangeCallback callback)

Methods inherited from class io.druid.server.coordination.BaseZkCoordinator

isStarted, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkCoordinator

@Inject
public ZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                    SegmentLoaderConfig config,
                    ZkPathsConfig zkPaths,
                    DruidServerMetadata me,
                    DataSegmentAnnouncer announcer,
                    org.apache.curator.framework.CuratorFramework curator,
                    ServerManager serverManager,
                    com.metamx.common.concurrent.ScheduledExecutorFactory factory)

Method Detail

loadLocalCache

public void loadLocalCache()

Specified by:

loadLocalCache in class BaseZkCoordinator

getDataSegmentChangeHandler

public DataSegmentChangeHandler getDataSegmentChangeHandler()

Specified by:

getDataSegmentChangeHandler in class BaseZkCoordinator

addSegment

public void addSegment(io.druid.timeline.DataSegment segment,
              DataSegmentChangeCallback callback)

removeSegment

public void removeSegment(io.druid.timeline.DataSegment segment,
                 DataSegmentChangeCallback callback)