使用Java代码向DataProc集群添加标签

import com.google.api.gax.longrunning.OperationFuture;
import com.google.cloud.dataproc.v1.ClusterControllerClient;
import com.google.cloud.dataproc.v1.ClusterControllerSettings;
import com.google.cloud.dataproc.v1.ClusterName;
import com.google.cloud.dataproc.v1.ClusterUpdate;
import com.google.cloud.dataproc.v1.UpdateClusterRequest;
import com.google.protobuf.FieldMask;
import java.io.IOException;
import java.util.concurrent.ExecutionException;

public class AddLabelToDataProcCluster {
    public static void main(String[] args) {
        String projectId = "your-project-id";
        String region = "your-region";
        String clusterName = "your-cluster-name";
        String labelKey = "your-label-key";
        String labelValue = "your-label-value";

        try (ClusterControllerClient clusterControllerClient = ClusterControllerClient.create(
                ClusterControllerSettings.newBuilder().build())) {

            ClusterName cluster = ClusterName.of(projectId, region, clusterName);
            ClusterUpdate clusterUpdate = ClusterUpdate.newBuilder()
                    .setName(cluster.toString())
                    .putLabels(labelKey, labelValue)
                    .build();

            FieldMask updateMask = FieldMask.newBuilder().addPaths("labels").build();
            UpdateClusterRequest updateClusterRequest = UpdateClusterRequest.newBuilder()
                    .setCluster(clusterUpdate)
                    .setUpdateMask(updateMask)
                    .build();

            OperationFuture<com.google.protobuf.Empty, com.google.cloud.dataproc.v1.ClusterOperationMetadata> response =
                    clusterControllerClient.updateClusterAsync(updateClusterRequest);

            response.get();

            System.out.println("Label added successfully to the DataProc cluster.");

        } catch (IOException | InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }
}