Package | Description |
---|---|
org.apache.hadoop.yarn.api.protocolrecords |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.api.records |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.server.api.protocolrecords |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Modifier and Type | Method and Description |
---|---|
abstract Map<String,Set<NodeId>> |
GetLabelsToNodesResponse.getLabelsToNodes() |
abstract Map<NodeId,Set<String>> |
GetNodesToLabelsResponse.getNodeToLabels() |
Modifier and Type | Method and Description |
---|---|
static GetNodesToLabelsResponse |
GetNodesToLabelsResponse.newInstance(Map<NodeId,Set<String>> map) |
static GetLabelsToNodesResponse |
GetLabelsToNodesResponse.newInstance(Map<String,Set<NodeId>> map) |
abstract void |
GetLabelsToNodesResponse.setLabelsToNodes(Map<String,Set<NodeId>> map) |
abstract void |
GetNodesToLabelsResponse.setNodeToLabels(Map<NodeId,Set<String>> map) |
Modifier and Type | Method and Description |
---|---|
static NodeId |
NodeId.fromString(String nodeIdStr) |
abstract NodeId |
ContainerReport.getAssignedNode()
Get the allocated
NodeId where container is running. |
abstract NodeId |
Container.getNodeId()
Get the identifier of the node on which the container is allocated.
|
abstract NodeId |
NodeReport.getNodeId()
Get the
NodeId of the node. |
abstract NodeId |
NMToken.getNodeId()
Get the
NodeId of the NodeManager for which the NMToken
is used to authenticate. |
static NodeId |
NodeId.newInstance(String host,
int port) |
Modifier and Type | Method and Description |
---|---|
int |
NodeId.compareTo(NodeId other) |
static Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
static Container |
Container.newInstance(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken,
ExecutionType executionType) |
static ContainerReport |
ContainerReport.newInstance(ContainerId containerId,
Resource allocatedResource,
NodeId assignedNode,
Priority priority,
long creationTime,
long finishTime,
String diagnosticInfo,
String logUrl,
int containerExitStatus,
ContainerState containerState,
String nodeHttpAddress) |
static ContainerReport |
ContainerReport.newInstance(ContainerId containerId,
Resource allocatedResource,
NodeId assignedNode,
Priority priority,
long creationTime,
long finishTime,
String diagnosticInfo,
String logUrl,
int containerExitStatus,
ContainerState containerState,
String nodeHttpAddress,
ExecutionType executionType) |
static NodeReport |
NodeReport.newInstance(NodeId nodeId,
NodeState nodeState,
String httpAddress,
String rackName,
Resource used,
Resource capability,
int numContainers,
String healthReport,
long lastHealthReportTime) |
static NodeReport |
NodeReport.newInstance(NodeId nodeId,
NodeState nodeState,
String httpAddress,
String rackName,
Resource used,
Resource capability,
int numContainers,
String healthReport,
long lastHealthReportTime,
Set<String> nodeLabels,
Integer decommissioningTimeout,
NodeUpdateType nodeUpdateType) |
static NMToken |
NMToken.newInstance(NodeId nodeId,
Token token) |
abstract void |
ContainerReport.setAssignedNode(NodeId nodeId) |
abstract void |
Container.setNodeId(NodeId nodeId) |
abstract void |
NodeReport.setNodeId(NodeId nodeId) |
abstract void |
NMToken.setNodeId(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
abstract Set<NodeId> |
CheckForDecommissioningNodesResponse.getDecommissioningNodes() |
abstract Map<NodeId,ResourceOption> |
UpdateNodeResourceRequest.getNodeResourceMap()
Get the map from
NodeId to ResourceOption . |
abstract Map<NodeId,Set<String>> |
ReplaceLabelsOnNodeRequest.getNodeToLabels() |
Modifier and Type | Method and Description |
---|---|
static UpdateNodeResourceRequest |
UpdateNodeResourceRequest.newInstance(Map<NodeId,ResourceOption> nodeResourceMap) |
static UpdateNodeResourceRequest |
UpdateNodeResourceRequest.newInstance(Map<NodeId,ResourceOption> nodeResourceMap,
String subClusterId) |
static ReplaceLabelsOnNodeRequest |
ReplaceLabelsOnNodeRequest.newInstance(Map<NodeId,Set<String>> map) |
static ReplaceLabelsOnNodeRequest |
ReplaceLabelsOnNodeRequest.newInstance(Map<NodeId,Set<String>> map,
String subClusterId) |
static CheckForDecommissioningNodesResponse |
CheckForDecommissioningNodesResponse.newInstance(Set<NodeId> decommissioningNodes) |
abstract void |
CheckForDecommissioningNodesResponse.setDecommissioningNodes(Set<NodeId> decommissioningNodes) |
abstract void |
UpdateNodeResourceRequest.setNodeResourceMap(Map<NodeId,ResourceOption> nodeResourceMap)
Set the map from
NodeId to ResourceOption . |
abstract void |
ReplaceLabelsOnNodeRequest.setNodeToLabels(Map<NodeId,Set<String>> map) |
Copyright © 2008–2024 Apache Software Foundation. All rights reserved.