Modifier and Type | Method and Description |
---|---|
List<NodeReport> |
ResourceMgrDelegate.getNodeReports(NodeState... states) |
Modifier and Type | Method and Description |
---|---|
static TaskTrackerInfo |
TypeConverter.fromYarn(NodeReport node) |
Modifier and Type | Method and Description |
---|---|
static TaskTrackerInfo[] |
TypeConverter.fromYarnNodes(List<NodeReport> nodes) |
Modifier and Type | Method and Description |
---|---|
List<NodeReport> |
JobUpdatedNodesEvent.getUpdatedNodes() |
Constructor and Description |
---|
JobUpdatedNodesEvent(JobId jobId,
List<NodeReport> updatedNodes) |
Modifier and Type | Method and Description |
---|---|
abstract List<NodeReport> |
GetClusterNodesResponse.getNodeReports()
Get
NodeReport for all nodes in the cluster. |
abstract List<NodeReport> |
AllocateResponse.getUpdatedNodes()
Get the list of updated
NodeReport s. |
Modifier and Type | Method and Description |
---|---|
static AllocateResponse |
AllocateResponse.newInstance(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt,
List<NMToken> nmTokens) |
static GetClusterNodesResponse |
GetClusterNodesResponse.newInstance(List<NodeReport> nodeReports) |
abstract void |
GetClusterNodesResponse.setNodeReports(List<NodeReport> nodeReports) |
abstract void |
AllocateResponse.setUpdatedNodes(List<NodeReport> updatedNodes) |
Modifier and Type | Method and Description |
---|---|
List<NodeReport> |
GetClusterNodesResponsePBImpl.getNodeReports() |
List<NodeReport> |
AllocateResponsePBImpl.getUpdatedNodes() |
Modifier and Type | Method and Description |
---|---|
void |
GetClusterNodesResponsePBImpl.setNodeReports(List<NodeReport> nodeManagers) |
void |
AllocateResponsePBImpl.setUpdatedNodes(List<NodeReport> updatedNodes) |
Modifier and Type | Method and Description |
---|---|
static NodeReport |
NodeReport.newInstance(NodeId nodeId,
NodeState nodeState,
String httpAddress,
String rackName,
Resource used,
Resource capability,
int numContainers,
String healthReport,
long lastHealthReportTime) |
Modifier and Type | Class and Description |
---|---|
class |
NodeReportPBImpl |
Modifier and Type | Method and Description |
---|---|
abstract List<NodeReport> |
YarnClient.getNodeReports(NodeState... states)
Get a report of nodes (
NodeReport ) in the cluster. |
Modifier and Type | Method and Description |
---|---|
void |
AMRMClientAsync.CallbackHandler.onNodesUpdated(List<NodeReport> updatedNodes)
Called when nodes tracked by the ResourceManager have changed in health,
availability etc.
|
Modifier and Type | Method and Description |
---|---|
List<NodeReport> |
YarnClientImpl.getNodeReports(NodeState... states) |
Modifier and Type | Method and Description |
---|---|
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 AllocateResponse |
BuilderUtils.newAllocateResponse(int responseId,
List<ContainerStatus> completedContainers,
List<Container> allocatedContainers,
List<NodeReport> updatedNodes,
Resource availResources,
AMCommand command,
int numClusterNodes,
PreemptionMessage preempt) |
Copyright © 2013 Apache Software Foundation. All rights reserved.