org.springframework.yarn.boot.app.YarnContainerClusterOperations.clusterCreate()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.5k)|赞(0)|评价(0)|浏览(94)

本文整理了Java中org.springframework.yarn.boot.app.YarnContainerClusterOperations.clusterCreate()方法的一些代码示例,展示了YarnContainerClusterOperations.clusterCreate()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。YarnContainerClusterOperations.clusterCreate()方法的具体详情如下:
包路径:org.springframework.yarn.boot.app.YarnContainerClusterOperations
类名称:YarnContainerClusterOperations
方法名:clusterCreate

YarnContainerClusterOperations.clusterCreate介绍

[英]Create a container cluster.
[中]创建一个容器集群。

代码示例

代码示例来源:origin: org.springframework.cloud/spring-cloud-deployer-yarn

public void createCluster(ApplicationId applicationId, String clusterId, String clusterDef, String projectionType,
    Integer projectionDataAny, Map<String, Integer> hosts, Map<String, Integer> racks,
    Map<String, Object> projectionDataProperties, Map<String, Object> extraProperties) {
  YarnContainerClusterOperations operations = buildClusterOperations(restTemplate, yarnClient, applicationId);
  ContainerClusterCreateRequest request = new ContainerClusterCreateRequest();
  request.setClusterId(clusterId);
  request.setClusterDef(clusterDef);
  request.setProjection(projectionType);
  request.setExtraProperties(extraProperties);
  ProjectionDataType projectionData = new ProjectionDataType();
  projectionData.setAny(projectionDataAny);
  projectionData.setHosts(hosts);
  projectionData.setRacks(racks);
  projectionData.setProperties(projectionDataProperties);
  request.setProjectionData(projectionData);
  operations.clusterCreate(request);
}

代码示例来源:origin: org.springframework.data/spring-yarn-boot

private String doClusterCreate(RestTemplate restTemplate, YarnClient client, ApplicationId applicationId, String clusterId, String clusterDef,
    String projectionType, Integer projectionDataAny, Map<String, Integer> hosts, Map<String, Integer> racks,
    Map<String, Object> projectionDataProperties, Map<String, Object> extraProperties) {
  YarnContainerClusterOperations operations = buildClusterOperations(restTemplate, client, applicationId);
  ContainerClusterCreateRequest request = new ContainerClusterCreateRequest();
  request.setClusterId(clusterId);
  request.setClusterDef(clusterDef);
  request.setProjection(projectionType);
  request.setExtraProperties(extraProperties);
  ProjectionDataType projectionData = new ProjectionDataType();
  projectionData.setAny(projectionDataAny);
  projectionData.setHosts(hosts);
  projectionData.setRacks(racks);
  projectionData.setProperties(projectionDataProperties);
  request.setProjectionData(projectionData);
  operations.clusterCreate(request);
  return "Cluster " + clusterId + " created.";
}

相关文章