io.druid.server.coordinator

Class DruidCoordinatorRuntimeParams

java.lang.Object

io.druid.server.coordinator.DruidCoordinatorRuntimeParams

public class DruidCoordinatorRuntimeParams
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DruidCoordinatorRuntimeParams.Builder

Constructor Summary

Constructors

Constructor and Description

DruidCoordinatorRuntimeParams(long startTime, DruidCluster druidCluster, MetadataRuleManager databaseRuleManager, SegmentReplicantLookup segmentReplicantLookup, Set<DruidDataSource> dataSources, Set<io.druid.timeline.DataSegment> availableSegments, Map<String,LoadQueuePeon> loadManagementPeons, ReplicationThrottler replicationManager, com.metamx.emitter.service.ServiceEmitter emitter, CoordinatorDynamicConfig coordinatorDynamicConfig, CoordinatorStats stats, org.joda.time.DateTime balancerReferenceTimestamp, BalancerStrategyFactory strategyFactory)

Method Summary

Methods

Modifier and Type	Method and Description
DruidCoordinatorRuntimeParams.Builder	buildFromExisting()
Set<io.druid.timeline.DataSegment>	getAvailableSegments()
org.joda.time.DateTime	getBalancerReferenceTimestamp()
BalancerStrategyFactory	getBalancerStrategyFactory()
CoordinatorDynamicConfig	getCoordinatorDynamicConfig()
CoordinatorStats	getCoordinatorStats()
MetadataRuleManager	getDatabaseRuleManager()
Set<DruidDataSource>	getDataSources()
DruidCluster	getDruidCluster()
com.metamx.emitter.service.ServiceEmitter	getEmitter()
Map<String,LoadQueuePeon>	getLoadManagementPeons()
ReplicationThrottler	getReplicationManager()
SegmentReplicantLookup	getSegmentReplicantLookup()
long	getStartTime()
boolean	hasDeletionWaitTimeElapsed()
static DruidCoordinatorRuntimeParams.Builder	newBuilder()

Methods inherited from class java.lang.Object

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

Constructor Detail

DruidCoordinatorRuntimeParams

public DruidCoordinatorRuntimeParams(long startTime,
                             DruidCluster druidCluster,
                             MetadataRuleManager databaseRuleManager,
                             SegmentReplicantLookup segmentReplicantLookup,
                             Set<DruidDataSource> dataSources,
                             Set<io.druid.timeline.DataSegment> availableSegments,
                             Map<String,LoadQueuePeon> loadManagementPeons,
                             ReplicationThrottler replicationManager,
                             com.metamx.emitter.service.ServiceEmitter emitter,
                             CoordinatorDynamicConfig coordinatorDynamicConfig,
                             CoordinatorStats stats,
                             org.joda.time.DateTime balancerReferenceTimestamp,
                             BalancerStrategyFactory strategyFactory)

Method Detail

getStartTime

public long getStartTime()

getDruidCluster

public DruidCluster getDruidCluster()

getDatabaseRuleManager

public MetadataRuleManager getDatabaseRuleManager()

getSegmentReplicantLookup

public SegmentReplicantLookup getSegmentReplicantLookup()

getDataSources

public Set<DruidDataSource> getDataSources()

getAvailableSegments

public Set<io.druid.timeline.DataSegment> getAvailableSegments()

getLoadManagementPeons

public Map<String,LoadQueuePeon> getLoadManagementPeons()

getReplicationManager

public ReplicationThrottler getReplicationManager()

getEmitter

public com.metamx.emitter.service.ServiceEmitter getEmitter()

getCoordinatorDynamicConfig

public CoordinatorDynamicConfig getCoordinatorDynamicConfig()

getCoordinatorStats

public CoordinatorStats getCoordinatorStats()

getBalancerReferenceTimestamp

public org.joda.time.DateTime getBalancerReferenceTimestamp()

getBalancerStrategyFactory

public BalancerStrategyFactory getBalancerStrategyFactory()

hasDeletionWaitTimeElapsed

public boolean hasDeletionWaitTimeElapsed()

newBuilder

public static DruidCoordinatorRuntimeParams.Builder newBuilder()

buildFromExisting

public DruidCoordinatorRuntimeParams.Builder buildFromExisting()