本文整理了Java中org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest类的一些代码示例，
本文整理了Java中org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest类的一些代码示例，展示了GetClusterNodesRequest类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。GetClusterNodesRequest类的具体详情如下：
包路径：org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest
类名称：GetClusterNodesRequest
GetClusterNodesRequest介绍
[英]The request from clients to get a report of all nodes in the cluster from the ResourceManager.
The request will ask for all nodes in the given NodeStates.
[中]客户端请求从ResourceManager获取集群中所有节点的报告。
该请求将请求给定节点属性中的所有节点。
代码示例
代码示例来源：origin: io.hops/hadoop-yarn-client
@Override
public List getNodeReports(NodeState... states) throws YarnException,
IOException {
EnumSet statesSet = (states.length == 0) ?
EnumSet.allOf(NodeState.class) : EnumSet.noneOf(NodeState.class);
for (NodeState state : states) {
statesSet.add(state);
}
GetClusterNodesRequest request = GetClusterNodesRequest
.newInstance(statesSet);
GetClusterNodesResponse respOnse= rmClient.getClusterNodes(request);
return response.getNodeReports();
}
代码示例来源：origin: org.apache.hadoop/hadoop-yarn-api
@Public
@Stable
public static GetClusterNodesRequest newInstance(EnumSet states) {
GetClusterNodesRequest request =
Records.newRecord(GetClusterNodesRequest.class);
request.setNodeStates(states);
return request;
}
代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager
@Override
public GetClusterNodesResponse getClusterNodes(GetClusterNodesRequest request)
throws YarnException {
GetClusterNodesResponse respOnse=
recordFactory.newRecordInstance(GetClusterNodesResponse.class);
EnumSet nodeStates = request.getNodeStates();
if (nodeStates == null || nodeStates.isEmpty()) {
nodeStates = EnumSet.allOf(NodeState.class);
}
Collection nodes = RMServerUtils.queryRMNodes(rmContext,
nodeStates);
List nodeReports = new ArrayList(nodes.size());
for (RMNode nodeInfo : nodes) {
nodeReports.add(createNodeReports(nodeInfo));
}
response.setNodeReports(nodeReports);
return response;
}
代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-client
@Override
public List getNodeReports(NodeState... states) throws YarnException,
IOException {
EnumSet statesSet = (states.length == 0) ?
EnumSet.allOf(NodeState.class) : EnumSet.noneOf(NodeState.class);
for (NodeState state : states) {
statesSet.add(state);
}
GetClusterNodesRequest request = GetClusterNodesRequest
.newInstance(statesSet);
GetClusterNodesResponse respOnse= rmClient.getClusterNodes(request);
return response.getNodeReports();
}
代码示例来源：origin: io.hops/hadoop-yarn-api
@Public
@Stable
public static GetClusterNodesRequest newInstance(EnumSet states) {
GetClusterNodesRequest request =
Records.newRecord(GetClusterNodesRequest.class);
request.setNodeStates(states);
return request;
}
代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager
@Override
public GetClusterNodesResponse getClusterNodes(GetClusterNodesRequest request)
throws YarnException {
GetClusterNodesResponse respOnse=
recordFactory.newRecordInstance(GetClusterNodesResponse.class);
EnumSet nodeStates = request.getNodeStates();
if (nodeStates == null || nodeStates.isEmpty()) {
nodeStates = EnumSet.allOf(NodeState.class);
}
Collection nodes = RMServerUtils.queryRMNodes(rmContext,
nodeStates);
List nodeReports = new ArrayList(nodes.size());
for (RMNode nodeInfo : nodes) {
nodeReports.add(createNodeReports(nodeInfo));
}
response.setNodeReports(nodeReports);
return response;
}
代码示例来源：origin: org.apache.hadoop/hadoop-yarn-client
@Override
public List getNodeReports(NodeState... states) throws YarnException,
IOException {
EnumSet statesSet = (states.length == 0) ?
EnumSet.allOf(NodeState.class) : EnumSet.noneOf(NodeState.class);
for (NodeState state : states) {
statesSet.add(state);
}
GetClusterNodesRequest request = GetClusterNodesRequest
.newInstance(statesSet);
GetClusterNodesResponse respOnse= rmClient.getClusterNodes(request);
return response.getNodeReports();
}
代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-api
@Public
@Stable
public static GetClusterNodesRequest newInstance(EnumSet states) {
GetClusterNodesRequest request =
Records.newRecord(GetClusterNodesRequest.class);
request.setNodeStates(states);
return request;
}
代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-resourcemanager
@Override
public GetClusterNodesResponse getClusterNodes(GetClusterNodesRequest request)
throws YarnException {
GetClusterNodesResponse respOnse=
recordFactory.newRecordInstance(GetClusterNodesResponse.class);
EnumSet nodeStates = request.getNodeStates();
if (nodeStates == null || nodeStates.isEmpty()) {
nodeStates = EnumSet.allOf(NodeState.class);
}
Collection nodes = RMServerUtils.queryRMNodes(rmContext,
nodeStates);
List nodeReports = new ArrayList(nodes.size());
for (RMNode nodeInfo : nodes) {
nodeReports.add(createNodeReports(nodeInfo));
}
response.setNodeReports(nodeReports);
return response;
}
代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-client
@Override
public List getNodeReports(NodeState... states) throws YarnException,
IOException {
EnumSet statesSet = (states.length == 0) ?
EnumSet.allOf(NodeState.class) : EnumSet.noneOf(NodeState.class);
for (NodeState state : states) {
statesSet.add(state);
}
GetClusterNodesRequest request = GetClusterNodesRequest
.newInstance(statesSet);
GetClusterNodesResponse respOnse= rmClient.getClusterNodes(request);
return response.getNodeReports();
}
代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-api
@Public
@Stable
public static GetClusterNodesRequest newInstance(EnumSet states) {
GetClusterNodesRequest request =
Records.newRecord(GetClusterNodesRequest.class);
request.setNodeStates(states);
return request;
}
代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager
@Test
public void testRMStartWithDecommissionedNode() throws Exception {
String excludeFile = "excludeFile";
createExcludeFile(excludeFile);
YarnConfiguration cOnf= new YarnConfiguration();
conf.set(YarnConfiguration.RM_NODES_EXCLUDE_FILE_PATH,
excludeFile);
MockRM rm = new MockRM(conf) {
protected ClientRMService createClientRMService() {
return new ClientRMService(this.rmContext, scheduler,
this.rmAppManager, this.applicationACLsManager, this.queueACLsManager,
this.getRMContext().getRMDelegationTokenSecretManager());
};
};
rm.start();
YarnRPC rpc = YarnRPC.create(conf);
InetSocketAddress rmAddress = rm.getClientRMService().getBindAddress();
LOG.info("Connecting to ResourceManager at " + rmAddress);
ApplicationClientProtocol client =
(ApplicationClientProtocol) rpc
.getProxy(ApplicationClientProtocol.class, rmAddress, conf);
// Make call
GetClusterNodesRequest request =
GetClusterNodesRequest.newInstance(EnumSet.allOf(NodeState.class));
List nodeReports = client.getClusterNodes(request).getNodeReports();
Assert.assertEquals(1, nodeReports.size());
rm.stop();
rpc.stopProxy(client, conf);
new File(excludeFile).delete();
}
代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager
GetClusterNodesRequest.newInstance(EnumSet.allOf(NodeState.class));
List nodeReports = client.getClusterNodes(request).getNodeReports();
Assert.assertEquals(1, nodeReports.size());
代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager
GetClusterNodesRequest.newInstance(EnumSet.of(NodeState.RUNNING));
List nodeReports =
client.getClusterNodes(request).getNodeReports();
request = GetClusterNodesRequest.newInstance(EnumSet.of(NodeState.UNHEALTHY));
nodeReports = client.getClusterNodes(request).getNodeReports();
Assert.assertEquals(1, nodeReports.size());
request = GetClusterNodesRequest.newInstance(EnumSet.allOf(NodeState.class));
nodeReports = client.getClusterNodes(request).getNodeReports();
Assert.assertEquals(3, nodeReports.size());
代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager
GetClusterNodesRequest.newInstance(EnumSet.of(NodeState.RUNNING));
List nodeReports =
client.getClusterNodes(request).getNodeReports();
request = GetClusterNodesRequest.newInstance(EnumSet.of(NodeState.UNHEALTHY));
nodeReports = client.getClusterNodes(request).getNodeReports();
Assert.assertEquals(1, nodeReports.size());
request = GetClusterNodesRequest.newInstance(EnumSet.allOf(NodeState.class));
nodeReports = client.getClusterNodes(request).getNodeReports();
Assert.assertEquals(3, nodeReports.size());
代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager
GetClusterNodesRequest.newInstance(
EnumSet.of(NodeState.DECOMMISSIONING)))
.getNodeReports();
代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager
GetClusterNodesRequest.newInstance(EnumSet.of(NodeState.RUNNING));
List nodeReports =
client.getClusterNodes(request).getNodeReports();
京公网安备 11010802041100号