org.apache.beam.it.gcp.dataflow

Class DirectRunnerClient

java.lang.Object

org.apache.beam.it.gcp.dataflow.DirectRunnerClient

All Implemented Interfaces:

org.apache.beam.it.common.PipelineLauncher

public class DirectRunnerClient
extends java.lang.Object
implements org.apache.beam.it.common.PipelineLauncher

Implementation of the PipelineLauncher interface which invokes the template class using DirectRunner, and manages the state in memory.

Nested Class Summary

Nested Classes

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

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

Method Summary

Modifier and Type	Method and Description
static DirectRunnerClient.Builder	builder(java.lang.Class<?> mainClass)
Job	cancelJob(java.lang.String project, java.lang.String region, java.lang.String jobId)
void	cleanupAll()
Job	drainJob(java.lang.String project, java.lang.String region, java.lang.String jobId)
Job	getJob(java.lang.String project, java.lang.String region, java.lang.String jobId)
Job	getJob(java.lang.String project, java.lang.String region, java.lang.String jobId, java.lang.String jobView)
org.apache.beam.it.common.PipelineLauncher.JobState	getJobStatus(java.lang.String project, java.lang.String region, java.lang.String jobId)
java.lang.Double	getMetric(java.lang.String project, java.lang.String region, java.lang.String jobId, java.lang.String metricName)
java.util.Map<java.lang.String,java.lang.Double>	getMetrics(java.lang.String project, java.lang.String region, java.lang.String jobId)
org.apache.beam.it.common.PipelineLauncher.LaunchInfo	launch(java.lang.String project, java.lang.String region, org.apache.beam.it.common.PipelineLauncher.LaunchConfig options)
java.util.List<JobMessage>	listMessages(java.lang.String project, java.lang.String region, java.lang.String jobId, java.lang.String minimumImportance)

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static DirectRunnerClient.Builder builder(java.lang.Class<?> mainClass)

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

Specified by:

launch in interface org.apache.beam.it.common.PipelineLauncher

Throws:

java.io.IOException

getJob

public Job getJob(java.lang.String project,
                  java.lang.String region,
                  java.lang.String jobId)

Specified by:

getJob in interface org.apache.beam.it.common.PipelineLauncher

getJob

public Job getJob(java.lang.String project,
                  java.lang.String region,
                  java.lang.String jobId,
                  java.lang.String jobView)

Specified by:

getJob in interface org.apache.beam.it.common.PipelineLauncher

getJobStatus

public org.apache.beam.it.common.PipelineLauncher.JobState getJobStatus(java.lang.String project,
                                                                        java.lang.String region,
                                                                        java.lang.String jobId)

Specified by:

getJobStatus in interface org.apache.beam.it.common.PipelineLauncher

listMessages

public java.util.List<JobMessage> listMessages(java.lang.String project,
                                               java.lang.String region,
                                               java.lang.String jobId,
                                               java.lang.String minimumImportance)

Specified by:

listMessages in interface org.apache.beam.it.common.PipelineLauncher

cancelJob

public Job cancelJob(java.lang.String project,
                     java.lang.String region,
                     java.lang.String jobId)

Specified by:

cancelJob in interface org.apache.beam.it.common.PipelineLauncher

drainJob

public Job drainJob(java.lang.String project,
                    java.lang.String region,
                    java.lang.String jobId)

Specified by:

drainJob in interface org.apache.beam.it.common.PipelineLauncher

getMetric

public java.lang.Double getMetric(java.lang.String project,
                                  java.lang.String region,
                                  java.lang.String jobId,
                                  java.lang.String metricName)

Specified by:

getMetric in interface org.apache.beam.it.common.PipelineLauncher

getMetrics

public java.util.Map<java.lang.String,java.lang.Double> getMetrics(java.lang.String project,
                                                                   java.lang.String region,
                                                                   java.lang.String jobId)
                                                            throws java.io.IOException

Specified by:

getMetrics in interface org.apache.beam.it.common.PipelineLauncher

Throws:

java.io.IOException

cleanupAll

public void cleanupAll()
                throws java.io.IOException

Specified by:

cleanupAll in interface org.apache.beam.it.common.PipelineLauncher

Throws:

java.io.IOException