com.google.cloud.dataflow.sdk.util

Class Transport

java.lang.Object

com.google.cloud.dataflow.sdk.util.Transport

public class Transport
extends Object

Helpers for cloud communication.

Constructor Summary

Constructors

Constructor and Description
Transport()

Method Summary

Modifier and Type	Method and Description
static com.google.api.client.json.JsonFactory	getJsonFactory()
static com.google.api.client.http.HttpTransport	getTransport()
static com.google.api.services.bigquery.Bigquery.Builder	newBigQueryClient(BigQueryOptions options) Returns a BigQuery client builder.
static com.google.api.services.dataflow.Dataflow.Builder	newDataflowClient(DataflowPipelineOptions options) Returns a Google Cloud Dataflow client builder.
static com.google.api.services.pubsub.Pubsub.Builder	newPubsubClient(DataflowPipelineOptions options) Returns a Pubsub client builder.
static com.google.api.services.dataflow.Dataflow.Builder	newRawDataflowClient(DataflowPipelineOptions options) Returns a Dataflow client that does not automatically retry failed requests.
static com.google.api.services.storage.Storage.Builder	newStorageClient(GcsOptions options) Returns a Cloud Storage client builder.

Methods inherited from class java.lang.Object

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

Constructor Detail

Transport

public Transport()

Method Detail

getTransport

public static com.google.api.client.http.HttpTransport getTransport()

getJsonFactory

public static com.google.api.client.json.JsonFactory getJsonFactory()

newBigQueryClient

public static com.google.api.services.bigquery.Bigquery.Builder newBigQueryClient(BigQueryOptions options)

Returns a BigQuery client builder.

Note: this client's endpoint is not modified by the DataflowPipelineDebugOptions.getApiRootUrl() option.

newPubsubClient

public static com.google.api.services.pubsub.Pubsub.Builder newPubsubClient(DataflowPipelineOptions options)

Returns a Pubsub client builder.

Note: this client's endpoint is not modified by the DataflowPipelineDebugOptions.getApiRootUrl() option.

newDataflowClient

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

Returns a Google Cloud Dataflow client builder.

newRawDataflowClient

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

Returns a Dataflow client that does not automatically retry failed requests.

newStorageClient

public static com.google.api.services.storage.Storage.Builder newStorageClient(GcsOptions options)

Returns a Cloud Storage client builder.

Note: this client's endpoint is not modified by the DataflowPipelineDebugOptions.getApiRootUrl() option.