org.apache.beam.it.gcp.dataflow

Class ClassicTemplateClient

java.lang.Object

org.apache.beam.it.gcp.dataflow.AbstractPipelineLauncher

org.apache.beam.it.gcp.dataflow.ClassicTemplateClient

All Implemented Interfaces:

org.apache.beam.it.common.PipelineLauncher

public final class ClassicTemplateClient
extends AbstractPipelineLauncher

Client for interacting with Dataflow classic templates using the Dataflow SDK.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClassicTemplateClient.Builder Builder for ClassicTemplateClient.

Nested classes/interfaces inherited from interface org.apache.beam.it.common.PipelineLauncher

org.apache.beam.it.common.PipelineLauncher.JobState, org.apache.beam.it.common.PipelineLauncher.LaunchConfig, org.apache.beam.it.common.PipelineLauncher.LaunchInfo, org.apache.beam.it.common.PipelineLauncher.Sdk

Field Summary

Fields inherited from class org.apache.beam.it.gcp.dataflow.AbstractPipelineLauncher

client, launchedJobs, LEGACY_RUNNER, PARAM_JOB_ID, PARAM_JOB_TYPE, PARAM_RUNNER, RUNNER_V2

Method Summary

Modifier and Type	Method and Description
static ClassicTemplateClient.Builder	builder(com.google.auth.Credentials credentials)
org.apache.beam.it.common.PipelineLauncher.LaunchInfo	launch(java.lang.String project, java.lang.String region, org.apache.beam.it.common.PipelineLauncher.LaunchConfig options)
static ClassicTemplateClient	withDataflowClient(Dataflow dataflow)

Methods inherited from class org.apache.beam.it.gcp.dataflow.AbstractPipelineLauncher

cancelJob, cleanupAll, drainJob, getJob, getJob, getJobInfo, getJobInfoBuilder, getJobStatus, getMetric, getMetrics, handleJobState, listMessages, printJobResponse, waitUntilActive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

withDataflowClient

public static ClassicTemplateClient withDataflowClient(Dataflow dataflow)

builder

public static ClassicTemplateClient.Builder builder(com.google.auth.Credentials credentials)

launch

public org.apache.beam.it.common.PipelineLauncher.LaunchInfo launch(java.lang.String project,
                                                                    java.lang.String region,
                                                                    org.apache.beam.it.common.PipelineLauncher.LaunchConfig options)
                                                             throws java.io.IOException

Throws:

java.io.IOException