Package | Description |
---|---|
org.apache.hadoop.yarn.api.records | |
org.apache.hadoop.yarn.client.api |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.hadoop.yarn.client.api.async | |
org.apache.hadoop.yarn.security |
Modifier and Type | Method and Description |
---|---|
abstract NodeId |
ContainerReport.getAssignedNode()
Get the allocated
NodeId where container is running. |
abstract NodeId |
NMToken.getNodeId()
Get the
NodeId of the NodeManager for which the NMToken
is used to authenticate. |
abstract NodeId |
NodeReport.getNodeId()
Get the
NodeId of the node. |
abstract NodeId |
Container.getNodeId()
Get the identifier of the node on which the container is allocated.
|
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 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 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) |
static NMToken |
NMToken.newInstance(NodeId nodeId,
Token token) |
abstract void |
ContainerReport.setAssignedNode(NodeId nodeId) |
abstract void |
NMToken.setNodeId(NodeId nodeId) |
abstract void |
NodeReport.setNodeId(NodeId nodeId) |
abstract void |
Container.setNodeId(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
abstract Map<String,Set<NodeId>> |
YarnClient.getLabelsToNodes()
The interface used by client to get labels to nodes mapping
in existing cluster
|
abstract Map<String,Set<NodeId>> |
YarnClient.getLabelsToNodes(Set<String> labels)
The interface used by client to get labels to nodes mapping
for specified labels in existing cluster
|
abstract Map<NodeId,Set<String>> |
YarnClient.getNodeToLabels()
The interface used by client to get node to labels mappings in existing cluster
|
Modifier and Type | Method and Description |
---|---|
abstract ContainerStatus |
NMClient.getContainerStatus(ContainerId containerId,
NodeId nodeId)
Query the status of a container.
|
abstract void |
NMClient.stopContainer(ContainerId containerId,
NodeId nodeId)
Stop an started container.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
NMClientAsync.getContainerStatusAsync(ContainerId containerId,
NodeId nodeId) |
abstract void |
NMClientAsync.stopContainerAsync(ContainerId containerId,
NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
NodeId |
NMTokenIdentifier.getNodeId() |
Constructor and Description |
---|
NMTokenIdentifier(ApplicationAttemptId appAttemptId,
NodeId nodeId,
String applicationSubmitter,
int masterKeyId) |
Copyright © 2015 Apache Software Foundation. All rights reserved.