public abstract class NodeLabelsStore extends Object implements Closeable
Modifier and Type | Field and Description |
---|---|
protected CommonNodeLabelsManager |
mgr |
Constructor and Description |
---|
NodeLabelsStore() |
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
|
protected CommonNodeLabelsManager mgr
public abstract void updateNodeToLabelsMappings(Map<org.apache.hadoop.yarn.api.records.NodeId,Set<String>> nodeToLabels) throws IOException
IOException
public abstract void storeNewClusterNodeLabels(List<org.apache.hadoop.yarn.api.records.NodeLabel> label) throws IOException
IOException
public abstract void removeClusterNodeLabels(Collection<String> labels) throws IOException
IOException
public abstract void recover() throws IOException, org.apache.hadoop.yarn.exceptions.YarnException
IOException
org.apache.hadoop.yarn.exceptions.YarnException
public void setNodeLabelsManager(CommonNodeLabelsManager mgr)
Copyright © 2008–2018 Apache Software Foundation. All rights reserved.