org.apache.druid.server.coordinator.rules

Class LoadRule

java.lang.Object

org.apache.druid.server.coordinator.rules.LoadRule

All Implemented Interfaces:

Rule

Direct Known Subclasses:

ForeverLoadRule, IntervalLoadRule, PeriodLoadRule

public abstract class LoadRule
extends Object
implements Rule

LoadRules indicate the number of replicants a segment should have in a given tier.

Constructor Summary

Constructors

Constructor and Description
LoadRule()

Method Summary

Modifier and Type	Method and Description
abstract int	getNumReplicants(String tier)
abstract Map<String,Integer>	getTieredReplicants()
CoordinatorStats	run(DruidCoordinator coordinator, DruidCoordinatorRuntimeParams params, org.apache.druid.timeline.DataSegment segment)
protected static void	validateTieredReplicants(Map<String,Integer> tieredReplicants)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.server.coordinator.rules.Rule

appliesTo, appliesTo, getType

Constructor Detail

LoadRule

public LoadRule()

Method Detail

run

public CoordinatorStats run(DruidCoordinator coordinator,
                            DruidCoordinatorRuntimeParams params,
                            org.apache.druid.timeline.DataSegment segment)

Specified by:

run in interface Rule

validateTieredReplicants

protected static void validateTieredReplicants(Map<String,Integer> tieredReplicants)

getTieredReplicants

public abstract Map<String,Integer> getTieredReplicants()

getNumReplicants

public abstract int getNumReplicants(String tier)