io.druid.server.coordination

Class ZkCoordinator

java.lang.Object

io.druid.server.coordination.ZkCoordinator

All Implemented Interfaces:

DataSegmentChangeHandler

public class ZkCoordinator
extends Object
implements DataSegmentChangeHandler

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, ScheduledExecutorFactory factory)

Method Summary

Modifier and Type	Method and Description
void	addSegment(DataSegment segment, DataSegmentChangeCallback callback)
DataSegmentChangeHandler	getDataSegmentChangeHandler()
Collection<DataSegment>	getPendingDeleteSnapshot()
boolean	isStarted()
void	loadLocalCache()
void	removeSegment(DataSegment segment, DataSegmentChangeCallback callback)
void	start()
void	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,
                             ScheduledExecutorFactory factory)

Method Detail

start

public void start()
           throws IOException

Throws:

IOException

stop

public void stop()

isStarted

public boolean isStarted()

loadLocalCache

public void loadLocalCache()

getDataSegmentChangeHandler

public DataSegmentChangeHandler getDataSegmentChangeHandler()

addSegment

public void addSegment(DataSegment segment,
                       DataSegmentChangeCallback callback)

Specified by:

addSegment in interface DataSegmentChangeHandler

removeSegment

public void removeSegment(DataSegment segment,
                          DataSegmentChangeCallback callback)

Specified by:

removeSegment in interface DataSegmentChangeHandler

getPendingDeleteSnapshot

public Collection<DataSegment> getPendingDeleteSnapshot()