问云函数在GCP中的调用

EN

public static void main(String a[]) throws IOException {

GoogleCredential credential = GoogleCredential.fromStream(new FileInputStream("My credential file location")).createScoped(
            java.util.Arrays.asList("https://www.googleapis.com/auth/cloud-platform"));
Dataproc dataproc = new Dataproc.Builder(new NetHttpTransport(), new JacksonFactory(), credential)
    .setApplicationName("my-webabb/1.0")
    .build();
String curJobId = "spark-job-" + UUID.randomUUID().toString();
Job jobSnapshot = null;
jobSnapshot = dataproc.projects().regions().jobs().submit(
                "gcp-project-name", "cluster-region", new SubmitJobRequest()
                    .setJob(new Job()
                        .setReference(new JobReference()
                            .setJobId(curJobId))
                        .setPlacement(new JobPlacement()
                            .setClusterName("cluster-name"))
                        .setSparkJob(new SparkJob()
                            .setMainClass("MainMethod")
                            .setJarFileUris(ImmutableList.of("jarfilelocation"))
                            )))
                .execute();
}

Dataproc dataproc = new Dataproc.Builder(new NetHttpTransport(), new JacksonFactory(), credential)
    .setApplicationName("my-webabb/1.0")
    .build();

        <dependency>
            <groupId>com.google.cloud</groupId>
            <artifactId>google-cloud-dataproc</artifactId>
            <version>1.5.2</version>
        </dependency>

public static void main(String a[])
        throws IOException, InterruptedException {
        String myEndpoint = String.format("%s-dataproc.googleapis.com:443", "us-central1");
        // Configure the settings for the job controller client.
        JobControllerSettings jobControllerSettings =
            JobControllerSettings.newBuilder().setEndpoint(myEndpoint).build();

        // Create a job controller client with the configured settings. Using a try-with-resources
        // closes the client,
        // but this can also be done manually with the .close() method.
        try (JobControllerClient jobControllerClient =
                 JobControllerClient.create(jobControllerSettings)) {

            // Configure cluster placement for the job.
            JobPlacement jobPlacement = JobPlacement.newBuilder().setClusterName("myclusterName").build();


            // Configure Spark job settings.
            SparkJob sparkJob =
                SparkJob.newBuilder()
                    .setMainClass("mymain")
                    .addJarFileUris("myJarFile")
                    .build();

            Job job =
                Job.newBuilder().setPlacement(jobPlacement).setSparkJob(sparkJob).build();

            // Submit an asynchronous request to execute the job.
            OperationFuture<Job, JobMetadata> submitJobAsOperationAsyncRequest =
                jobControllerClient.submitJobAsOperationAsync("myProjectId", "us-central1", job);

            Job response = submitJobAsOperationAsyncRequest.get();

            // Print output from Google Cloud Storage.
            Matcher matches =
                Pattern.compile("gs://(.*?)/(.*)").matcher(response.getDriverOutputResourceUri());
            matches.matches();

        } catch (ExecutionException e) {
            // If the job does not complete successfully, print the error message.
            System.err.println(String.format("submitJob: %s ", e.getMessage()));
        }
    }