Modifier and Type | Method and Description |
---|---|
NodeId |
TaskAttempt.getNodeId() |
Modifier and Type | Method and Description |
---|---|
NodeId |
TaskAttemptImpl.getNodeId() |
Modifier and Type | Method and Description |
---|---|
NodeId |
CompletedTaskAttempt.getNodeId() |
Modifier and Type | Method and Description |
---|---|
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. |
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 NodeReport |
NodeReport.newInstance(NodeId nodeId,
NodeState nodeState,
String httpAddress,
String rackName,
Resource used,
Resource capability,
int numContainers,
String healthReport,
long lastHealthReportTime) |
static NMToken |
NMToken.newInstance(NodeId nodeId,
Token token) |
abstract void |
NodeReport.setNodeId(NodeId nodeId) |
abstract void |
NMToken.setNodeId(NodeId nodeId) |
abstract void |
Container.setNodeId(NodeId nodeId) |
Modifier and Type | Class and Description |
---|---|
class |
NodeIdPBImpl |
Modifier and Type | Method and Description |
---|---|
static NodeId |
ProtoUtils.convertFromProtoFormat(YarnProtos.NodeIdProto e) |
NodeId |
ContainerPBImpl.getNodeId() |
NodeId |
NMTokenPBImpl.getNodeId() |
NodeId |
NodeReportPBImpl.getNodeId() |
Modifier and Type | Method and Description |
---|---|
static YarnProtos.NodeIdProto |
ProtoUtils.convertToProtoFormat(NodeId e) |
void |
ContainerPBImpl.setNodeId(NodeId nodeId) |
void |
NMTokenPBImpl.setNodeId(NodeId nodeId) |
void |
NodeReportPBImpl.setNodeId(NodeId nodeId) |
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 |
NMClientAsyncImpl.ContainerEvent.getNodeId() |
Modifier and Type | Method and Description |
---|---|
void |
NMClientAsyncImpl.getContainerStatusAsync(ContainerId containerId,
NodeId nodeId) |
void |
NMClientAsyncImpl.stopContainerAsync(ContainerId containerId,
NodeId nodeId) |
Constructor and Description |
---|
NMClientAsyncImpl.ContainerEvent(ContainerId containerId,
NodeId nodeId,
Token containerToken,
NMClientAsyncImpl.ContainerEventType type) |
Modifier and Type | Method and Description |
---|---|
NodeId |
NMClientImpl.StartedContainer.getNodeId() |
Modifier and Type | Method and Description |
---|---|
ContainerStatus |
NMClientImpl.getContainerStatus(ContainerId containerId,
NodeId nodeId) |
void |
NMClientImpl.stopContainer(ContainerId containerId,
NodeId nodeId) |
Constructor and Description |
---|
NMClientImpl.StartedContainer(ContainerId containerId,
NodeId nodeId,
Token containerToken) |
Modifier and Type | Method and Description |
---|---|
static Path |
LogAggregationUtils.getRemoteNodeLogFileForApp(Path remoteRootLogDir,
ApplicationId appId,
String user,
NodeId nodeId,
String suffix)
Constructs the full filename for an application's log file per node.
|
Modifier and Type | Method and Description |
---|---|
NodeId |
NMTokenIdentifier.getNodeId() |
Constructor and Description |
---|
NMTokenIdentifier(ApplicationAttemptId appAttemptId,
NodeId nodeId,
String applicationSubmitter,
int masterKeyId) |
Modifier and Type | Method and Description |
---|---|
NodeId |
RegisterNodeManagerRequest.getNodeId() |
Modifier and Type | Method and Description |
---|---|
void |
RegisterNodeManagerRequest.setNodeId(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
NodeId |
RegisterNodeManagerRequestPBImpl.getNodeId() |
Modifier and Type | Method and Description |
---|---|
void |
RegisterNodeManagerRequestPBImpl.setNodeId(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
NodeId |
NodeStatus.getNodeId() |
Modifier and Type | Method and Description |
---|---|
void |
NodeStatus.setNodeId(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
NodeId |
NodeStatusPBImpl.getNodeId() |
Modifier and Type | Method and Description |
---|---|
void |
NodeStatusPBImpl.setNodeId(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
NodeId |
NodeManager.NMContext.getNodeId()
Usable only after ContainerManager is started.
|
NodeId |
Context.getNodeId()
Return the nodeId.
|
Modifier and Type | Method and Description |
---|---|
void |
NodeManager.NMContext.setNodeId(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
NodeId |
NMTokenSecretManagerInNM.getNodeId() |
Modifier and Type | Method and Description |
---|---|
void |
NMContainerTokenSecretManager.setNodeId(NodeId nodeId) |
void |
NMTokenSecretManagerInNM.setNodeId(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<NodeId,RMNode> |
RMContextImpl.getRMNodes() |
ConcurrentMap<NodeId,RMNode> |
RMContext.getRMNodes() |
Modifier and Type | Method and Description |
---|---|
protected void |
NMLivelinessMonitor.expire(NodeId id) |
Modifier and Type | Method and Description |
---|---|
Set<NodeId> |
RMAppAttempt.getRanNodes()
Nodes on which the containers for this
RMAppAttempt ran. |
Set<NodeId> |
RMAppAttemptImpl.getRanNodes() |
Modifier and Type | Method and Description |
---|---|
NodeId |
RMContainerImpl.getReservedNode() |
NodeId |
RMContainer.getReservedNode() |
NodeId |
RMContainerReservedEvent.getReservedNode() |
Constructor and Description |
---|
RMContainerImpl(Container container,
ApplicationAttemptId appAttemptId,
NodeId nodeId,
EventHandler handler,
ContainerAllocationExpirer containerAllocationExpirer) |
RMContainerReservedEvent(ContainerId containerId,
Resource reservedResource,
NodeId reservedNode,
Priority reservedPriority) |
Modifier and Type | Method and Description |
---|---|
NodeId |
RMNodeEvent.getNodeId() |
NodeId |
RMNodeImpl.getNodeID() |
NodeId |
RMNode.getNodeID()
the node id of of this node.
|
Constructor and Description |
---|
RMNodeCleanAppEvent(NodeId nodeId,
ApplicationId appId) |
RMNodeCleanContainerEvent(NodeId nodeId,
ContainerId contId) |
RMNodeEvent(NodeId nodeId,
RMNodeEventType type) |
RMNodeImpl(NodeId nodeId,
RMContext context,
String hostName,
int cmPort,
int httpPort,
Node node,
Resource capability) |
RMNodeReconnectEvent(NodeId nodeId,
RMNode newNode) |
RMNodeStatusEvent(NodeId nodeId,
NodeHealthStatus nodeHealthStatus,
List<ContainerStatus> collection,
List<ApplicationId> keepAliveAppIds,
NodeHeartbeatResponse latestResponse) |
Modifier and Type | Method and Description |
---|---|
SchedulerNodeReport |
YarnScheduler.getNodeReport(NodeId nodeId)
Get node resource usage report.
|
Modifier and Type | Method and Description |
---|---|
SchedulerNodeReport |
CapacityScheduler.getNodeReport(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
NodeId |
FiCaSchedulerNode.getNodeID() |
Modifier and Type | Method and Description |
---|---|
void |
FiCaSchedulerApp.containerLaunchedOnNode(ContainerId containerId,
NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
NodeId |
FSSchedulerNode.getNodeID() |
Modifier and Type | Method and Description |
---|---|
void |
FSSchedulerApp.containerLaunchedOnNode(ContainerId containerId,
NodeId nodeId) |
SchedulerNodeReport |
FairScheduler.getNodeReport(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
SchedulerNodeReport |
FifoScheduler.getNodeReport(NodeId nodeId) |
Modifier and Type | Method and Description |
---|---|
Token |
RMContainerTokenSecretManager.createContainerToken(ContainerId containerId,
NodeId nodeId,
String appSubmitter,
Resource capability)
Helper function for creating ContainerTokens
|
boolean |
NMTokenSecretManagerInRM.isApplicationAttemptNMTokenPresent(ApplicationAttemptId appAttemptId,
NodeId nodeId) |
void |
NMTokenSecretManagerInRM.removeNodeKey(NodeId nodeId)
This is to be called when NodeManager reconnects or goes down.
|
Modifier and Type | Method and Description |
---|---|
Token |
BaseNMTokenSecretManager.createNMToken(ApplicationAttemptId applicationAttemptId,
NodeId nodeId,
String applicationSubmitter)
Helper function for creating NMTokens.
|
Modifier and Type | Method and Description |
---|---|
static NodeId |
BuilderUtils.newNodeId(String host,
int port) |
Modifier and Type | Method and Description |
---|---|
static Container |
BuilderUtils.newContainer(ContainerId containerId,
NodeId nodeId,
String nodeHttpAddress,
Resource resource,
Priority priority,
Token containerToken) |
static Token |
BuilderUtils.newContainerToken(NodeId nodeId,
byte[] password,
ContainerTokenIdentifier tokenIdentifier) |
static NodeReport |
BuilderUtils.newNodeReport(NodeId nodeId,
NodeState nodeState,
String httpAddress,
String rackName,
Resource used,
Resource capability,
int numContainers,
String healthReport,
long lastHealthReportTime) |
Modifier and Type | Method and Description |
---|---|
static NodeId |
ConverterUtils.toNodeId(String nodeIdStr) |
Copyright © 2013 Apache Software Foundation. All rights reserved.