io.druid.server.bridge

Class BridgeZkCoordinator

java.lang.Object

io.druid.server.coordination.BaseZkCoordinator

io.druid.server.bridge.BridgeZkCoordinator

All Implemented Interfaces:

DataSegmentChangeHandler

public class BridgeZkCoordinator
extends BaseZkCoordinator

Constructor Summary

Constructors

Constructor and Description
BridgeZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, ZkPathsConfig zkPaths, SegmentLoaderConfig config, DruidServerMetadata me, org.apache.curator.framework.CuratorFramework curator, DbSegmentPublisher dbSegmentPublisher, DatabaseSegmentManager databaseSegmentManager, ServerView serverView)

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

getLoadingExecutor, isStarted, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

BridgeZkCoordinator

@Inject
public BridgeZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                          ZkPathsConfig zkPaths,
                          SegmentLoaderConfig config,
                          DruidServerMetadata me,
                          org.apache.curator.framework.CuratorFramework curator,
                          DbSegmentPublisher dbSegmentPublisher,
                          DatabaseSegmentManager databaseSegmentManager,
                          ServerView serverView)

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)