public void createCluster(BmrClient bmrClient) {
    // 发送创建集群请求
    String clusterId = null;
    try {
        CreateClusterResponse response = bmrClient.createCluster(
                new CreateClusterRequest()
                        .withName("java-sdk-cluster")
                        .withImageType("hadoop")
                        .withImageVersion("0.1.0")
                        .withAutoTerminate(false)
                        .withLogUri("bos://path/to/logUri/")
                        .withServiceHaEnabled(false)
                        .withSafeModeEnabled(false)
                        .withInstanceGroup(new InstanceGroupConfig()
                                .withName("ig-master")
                                .withType("Master")
                                .withInstanceType("bmr.g1.2xlarge")
                                .withInstanceCount(1)
                                .withRootDiskSizeInGB(50)
                                .withRootDiskMediumType("ssd")
                                .withCds(new CdsItem()
                                    .withSizeInGB(100)
                                    .withMediumType("ssd")))
                        .withInstanceGroup(new InstanceGroupConfig()
                                .withName("ig-core")
                                .withType("Core")
                                .withInstanceType("bmr.gh1.large")
                                .withInstanceCount(2)
                                .withRootDiskSizeInGB(50)
                                .withRootDiskMediumType("ssd"))
                        .withApplication(new PigApplicationConfig().withVersion("0.11.0"))
                        .withApplication(new HiveApplicationConfig().withVersion("0.13.0").withMetastore("default"))
                        .withApplication(new HBaseApplicationConfig()
                                .withVersion("0.98.0")
                                .withBackupEnabled(true)
                                .withBackupLocation("bos://tester01/hbase_backup")
                                .withBackupIntervalInMinutes(300)
                                .withBackupStartDatetime("2015-08-18T23:00:00Z"))
                        .withStep(new JavaStepConfig()
                                .withName("init-step")
                                .withActionOnFailure("Continue")
                                .withJar("bos://bmr/samples/mapreduce/libs/hadoop-mapreduce-examples.jar")
                                .withMainClass("org.apache.hadoop.examples.WordCount")
                                .withArguments("bos://bmr/samples/mapreduce/wordcount/hamlet.txt bos://tester01/out"))
        );
        // 获取新创建集群的集群ID。
        clusterId = response.getClusterId();
    } catch (BceServiceException e) {
        System.out.println("Create cluster failed: " + e.getErrorMessage());
    } catch (BceClientException e) {
        System.out.println(e.getMessage());
    }
}

public void listClusters(BmrClient bmrClient) {
	int maxKeys = 10;
    try {
        // 方法 1. 默认的查询请求
        ListClustersResponse response1 = bmrClient.listClusters();

        // 方法 2. 配置maxKeys的单次查询请求
        ListClustersResponse response2 = bmrClient.listClusters(maxKeys);
         // 方法 3. 配置maxKeys和marker参数的循环查询请求
        boolean isTruncated = true;
        int page = 0;
        String marker = null;
        while (isTruncated) {
           ListClustersResponse response3 = bmrClient.listClusters(marker, maxKeys);	
           page++;
           System.out.format("Page %d: cluster count: %d\n", page, response3.getClusters().size());
           isTruncated = response3.isTruncated();	
           marker = response3.getNextMarker();	
        }

        // 方法 4. 自定义ListClustersResquest对象的查询请求
        ListClustersResponse response4 = bmrClient.listClusters(
                new ListClustersRequest().withMaxKeys(maxKeys)
        );

        // 输出各个集群的ID
        for (Cluster cluster : response4.getClusters()) {
            System.out.format("cluster id: %s\n", cluster.getId());
        }
    } catch (BceServiceException e) {
        System.out.println("List clusters failed: " + e.getErrorMessage());
    }
}

public class Cluster {
    private String payType;                                  //集群支付方式
    private boolean enableAutoScale;                         //集群是否支持自动扩缩容
    private Date createTime;                                 //集群创建时间
    private List<Tag> tags;                                  // 标签
    private List<Application> applications;                  // 集群已安装的应用信息
    private String id;                                       // 集群ID
    private String name;                                     // 集群名称
    private String imageType;                                // 集群虚拟机实例的镜像类型
    private String imageVersion;                             // 集群虚拟机实例的镜像版本
    private ClusterStatus status;                            // 集群当前的状态信息
}

public class ClusterStatus {
private String code;                                       // 集群创建失败的错误码
private String message;                                    // 集群创建失败的错误信息
private String orderStatus;                                // 订单状态
private Date expireDateTime;                               // 过期时间
private int expireDates;                                   // 过期日期

    private String state;                                    // 集群状态字段
    private Date creationDateTime;                           // 集群创建时间
    private Date endDateTime;                                // 集群终止时间
    private Date readyDateTime;                              // 集群完成部署时间
}

public void getCluster(BmrClient bmrClient, String clusterId) {
    try {
        // 方法 1. 查询对应ID的集群信息
        GetClusterResponse response1 = bmrClient.getCluster(clusterId);

        // 方法 2. 自定义GetClusterRequest对象的查询请求
        GetClusterResponse response2 = bmrClient.getCluster(
                new GetClusterRequest().withClusterId(clusterId)
        );
        // 输出集群的镜像类型
        System.out.println(response1.getImageType());
        // 输出集群当前的状态
        System.out.println(response2.getStatus().getState());
    } catch (BceServiceException e) {
        System.out.println("Describe cluster failed: " +  e.getErrorMessage());
    }
}

public void terminateCluster(BmrClient bmrClient, String clusterId) {
    try {
    	// 方法 1. 终止对应ID的集群
        bmrClient.terminateCluster(clusterId);

        /*
        方法 2. 自定义TerminateClusterRequest对象的终止请求
        bmrClient.terminateCluster(
                new TerminateClusterRequest().withClusterId(clusterId)
        );
        */
    } catch (BceServiceException e) {
        System.out.println("Terminate cluster failed: " + e.getErrorMessage());
    }
}