org.apache.beam.it.gcp.dataflow

Class FlexTemplateClient

java.lang.Object

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

org.apache.beam.it.gcp.dataflow.FlexTemplateClient

All Implemented Interfaces:

org.apache.beam.it.common.PipelineLauncher

public final class FlexTemplateClient
extends AbstractPipelineLauncher

Client for interacting with Dataflow Flex Templates using the Dataflow SDK.

Nested Class Summary

Nested Classes

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

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 FlexTemplateClient.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 FlexTemplateClient	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 FlexTemplateClient withDataflowClient(Dataflow dataflow)

builder

public static FlexTemplateClient.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