org.apache.beam.runners.dataflow.util

Class DataflowTransport

java.lang.Object

org.apache.beam.runners.dataflow.util.DataflowTransport

public class DataflowTransport
extends java.lang.Object

Helpers for cloud communication.

Constructor Summary

Constructors

Constructor and Description
DataflowTransport()

Method Summary

Modifier and Type	Method and Description
static com.google.api.services.clouddebugger.v2.Clouddebugger.Builder	newClouddebuggerClient(DataflowPipelineOptions options)
static com.google.api.services.dataflow.Dataflow.Builder	newDataflowClient(DataflowPipelineOptions options) Returns a Google Cloud Dataflow client builder.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataflowTransport

public DataflowTransport()

Method Detail

newDataflowClient

public static com.google.api.services.dataflow.Dataflow.Builder newDataflowClient(DataflowPipelineOptions options)

Returns a Google Cloud Dataflow client builder.

newClouddebuggerClient

public static com.google.api.services.clouddebugger.v2.Clouddebugger.Builder newClouddebuggerClient(DataflowPipelineOptions options)