Package org.apache.hadoop.yarn.server.resourcemanager.scheduler.placement

Class MultiNodeSortingManager<N extends SchedulerNode>

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.server.resourcemanager.scheduler.placement.MultiNodeSortingManager<N>

Type Parameters:

N - extends SchedulerNode

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service

public class MultiNodeSortingManager<N extends SchedulerNode>
extends org.apache.hadoop.service.AbstractService

Node Sorting Manager which runs all sorter threads and policies.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor	Description
MultiNodeSortingManager()

Method Summary

Modifier and Type	Method	Description
MultiNodeSorter<N>	getMultiNodePolicy(String name)
Iterator<N>	getMultiNodeSortIterator(Collection<N> nodes, String partition, String policyName)
void	registerMultiNodePolicyNames(boolean isMultiNodePlacementEnabled, Set<MultiNodePolicySpec> multiNodePlacementPolicies)
void	serviceInit(org.apache.hadoop.conf.Configuration configuration)
void	serviceStart()
void	serviceStop()
void	setRMContext(RMContext context)

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Constructor Details

MultiNodeSortingManager

public MultiNodeSortingManager()

Method Details

serviceInit

public void serviceInit(org.apache.hadoop.conf.Configuration configuration)
                 throws Exception

Overrides:

serviceInit in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStart

public void serviceStart()
                  throws Exception

Overrides:

serviceStart in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStop

public void serviceStop()
                 throws Exception

Overrides:

serviceStop in class org.apache.hadoop.service.AbstractService

Throws:

Exception

getMultiNodePolicy

public MultiNodeSorter<N> getMultiNodePolicy(String name)

setRMContext

public void setRMContext(RMContext context)

registerMultiNodePolicyNames

public void registerMultiNodePolicyNames(boolean isMultiNodePlacementEnabled,
 Set<MultiNodePolicySpec> multiNodePlacementPolicies)

getMultiNodeSortIterator

public Iterator<N> getMultiNodeSortIterator(Collection<N> nodes,
 String partition,
 String policyName)