Package org.apache.hadoop.yarn.server.resourcemanager.monitor.invariants

Class InvariantsChecker

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.monitor.invariants.InvariantsChecker

All Implemented Interfaces:

SchedulingEditPolicy

Direct Known Subclasses:

MetricsInvariantChecker, ReservationInvariantsChecker

public abstract class InvariantsChecker
extends Object
implements SchedulingEditPolicy

Abstract invariant checker, that setup common context for invariants checkers.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	INVARIANT_MONITOR_INTERVAL
static final String	THROW_ON_VIOLATION

Constructor Summary

Constructors

Constructor	Description
InvariantsChecker()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.conf.Configuration	getConf()
RMContext	getContext()
long	getMonitoringInterval()
String	getPolicyName()
ResourceScheduler	getScheduler()
boolean	getThrowOnInvariantViolation()
void	init(org.apache.hadoop.conf.Configuration config, RMContext rmContext, ResourceScheduler scheduler)
void	logOrThrow(String message)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.yarn.server.resourcemanager.monitor.SchedulingEditPolicy

editSchedule

Field Details

THROW_ON_VIOLATION

public static final String THROW_ON_VIOLATION

See Also:

• Constant Field Values

INVARIANT_MONITOR_INTERVAL

public static final String INVARIANT_MONITOR_INTERVAL

See Also:

• Constant Field Values

Constructor Details

InvariantsChecker

public InvariantsChecker()

Method Details

init

public void init(org.apache.hadoop.conf.Configuration config,
 RMContext rmContext,
 ResourceScheduler scheduler)

Specified by:

init in interface SchedulingEditPolicy

getMonitoringInterval

public long getMonitoringInterval()

Specified by:

getMonitoringInterval in interface SchedulingEditPolicy

getPolicyName

public String getPolicyName()

Specified by:

getPolicyName in interface SchedulingEditPolicy

logOrThrow

public void logOrThrow(String message)
                throws InvariantViolationException

Throws:

InvariantViolationException

getThrowOnInvariantViolation

public boolean getThrowOnInvariantViolation()

getConf

public org.apache.hadoop.conf.Configuration getConf()

getContext

public RMContext getContext()

getScheduler

public ResourceScheduler getScheduler()