io.druid.server.coordinator

Class DruidCoordinator

java.lang.Object

io.druid.server.coordinator.DruidCoordinator

public class DruidCoordinator
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DruidCoordinator.CoordinatorRunnable

Field Summary

Fields

Modifier and Type	Field and Description
static String	COORDINATOR_OWNER_NODE
static Comparator<DataSegment>	SEGMENT_COMPARATOR

Constructor Summary

Constructors

Constructor and Description

DruidCoordinator(DruidCoordinatorConfig config, ZkPathsConfig zkPaths, JacksonConfigManager configManager, MetadataSegmentManager metadataSegmentManager, ServerInventoryView serverInventoryView, MetadataRuleManager metadataRuleManager, org.apache.curator.framework.CuratorFramework curator, com.metamx.emitter.service.ServiceEmitter emitter, ScheduledExecutorFactory scheduledExecutorFactory, IndexingServiceClient indexingServiceClient, LoadQueueTaskMaster taskMaster, ServiceAnnouncer serviceAnnouncer, DruidNode self, Set<DruidCoordinatorHelper> indexingServiceHelpers, BalancerStrategyFactory factory)

Method Summary

Modifier and Type	Method and Description
void	enableDatasource(String ds)
Iterable<DataSegment>	getAvailableDataSegments()
String	getCurrentLeader()
CoordinatorDynamicConfig	getDynamicConfigs()
Map<String,LoadQueuePeon>	getLoadManagementPeons()
Map<String,Double>	getLoadStatus()
Set<DataSegment>	getOrderedAvailableDataSegments()
Map<String,CountingMap<String>>	getReplicationStatus()
CountingMap<String>	getSegmentAvailability()
boolean	isLeader()
void	moveSegment(ImmutableDruidServer fromServer, ImmutableDruidServer toServer, String segmentName, LoadPeonCallback callback)
void	removeDatasource(String ds)
void	removeSegment(DataSegment segment)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

COORDINATOR_OWNER_NODE

public static final String COORDINATOR_OWNER_NODE

See Also:

Constant Field Values

SEGMENT_COMPARATOR

public static Comparator<DataSegment> SEGMENT_COMPARATOR

Constructor Detail

DruidCoordinator

@Inject
public DruidCoordinator(DruidCoordinatorConfig config,
                                ZkPathsConfig zkPaths,
                                JacksonConfigManager configManager,
                                MetadataSegmentManager metadataSegmentManager,
                                ServerInventoryView serverInventoryView,
                                MetadataRuleManager metadataRuleManager,
                                org.apache.curator.framework.CuratorFramework curator,
                                com.metamx.emitter.service.ServiceEmitter emitter,
                                ScheduledExecutorFactory scheduledExecutorFactory,
                                IndexingServiceClient indexingServiceClient,
                                LoadQueueTaskMaster taskMaster,
                                ServiceAnnouncer serviceAnnouncer,
                                DruidNode self,
                                Set<DruidCoordinatorHelper> indexingServiceHelpers,
                                BalancerStrategyFactory factory)

Method Detail

isLeader

public boolean isLeader()

getLoadManagementPeons

public Map<String,LoadQueuePeon> getLoadManagementPeons()

getReplicationStatus

public Map<String,CountingMap<String>> getReplicationStatus()

getSegmentAvailability

public CountingMap<String> getSegmentAvailability()

getLoadStatus

public Map<String,Double> getLoadStatus()

getDynamicConfigs

public CoordinatorDynamicConfig getDynamicConfigs()

removeSegment

public void removeSegment(DataSegment segment)

removeDatasource

public void removeDatasource(String ds)

enableDatasource

public void enableDatasource(String ds)

getCurrentLeader

public String getCurrentLeader()

moveSegment

public void moveSegment(ImmutableDruidServer fromServer,
                        ImmutableDruidServer toServer,
                        String segmentName,
                        LoadPeonCallback callback)

getOrderedAvailableDataSegments

public Set<DataSegment> getOrderedAvailableDataSegments()

getAvailableDataSegments

public Iterable<DataSegment> getAvailableDataSegments()

start

public void start()

stop

public void stop()