org.apache.hadoop.yarn.nodelabels

Class NodeLabelsStore

java.lang.Object

org.apache.hadoop.yarn.nodelabels.NodeLabelsStore

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

FileSystemNodeLabelsStore

public abstract class NodeLabelsStore
extends Object
implements Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected CommonNodeLabelsManager	mgr

Constructor Summary

Constructors

Constructor and Description
NodeLabelsStore()

Method Summary

Methods

Modifier and Type	Method and Description
void	init(org.apache.hadoop.conf.Configuration conf)
abstract void	recover() Recover labels and node to labels mappings from store, but if ignoreNodeToLabelsMappings is true then node to labels mappings should not be recovered.
abstract void	removeClusterNodeLabels(Collection<String> labels) Remove labels
void	setNodeLabelsManager(CommonNodeLabelsManager mgr)
abstract void	storeNewClusterNodeLabels(List<org.apache.hadoop.yarn.api.records.NodeLabel> label) Store new labels
abstract void	updateNodeToLabelsMappings(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> nodeToLabels) Store node -> label

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Field Detail

mgr

protected CommonNodeLabelsManager mgr

Constructor Detail

NodeLabelsStore

public NodeLabelsStore()

Method Detail

updateNodeToLabelsMappings

public abstract void updateNodeToLabelsMappings(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> nodeToLabels)
                                         throws IOException

Store node -> label

Throws:

IOException

storeNewClusterNodeLabels

public abstract void storeNewClusterNodeLabels(List<org.apache.hadoop.yarn.api.records.NodeLabel> label)
                                        throws IOException

Store new labels

Throws:

IOException

removeClusterNodeLabels

public abstract void removeClusterNodeLabels(Collection<String> labels)
                                      throws IOException

Remove labels

Throws:

IOException

recover

public abstract void recover()
                      throws IOException,
                             org.apache.hadoop.yarn.exceptions.YarnException

Recover labels and node to labels mappings from store, but if ignoreNodeToLabelsMappings is true then node to labels mappings should not be recovered. In case of Distributed NodeLabels setup ignoreNodeToLabelsMappings will be set to true and recover will be invoked as RM will collect the node labels from NM through registration/HB

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

init

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

Throws:

Exception

setNodeLabelsManager

public void setNodeLabelsManager(CommonNodeLabelsManager mgr)