org.apache.beam.sdk.io.gcp.bigquery

Interface BigQueryServices

All Superinterfaces:

java.io.Serializable

public interface BigQueryServices
extends java.io.Serializable

An interface for real, mock, or fake implementations of Cloud BigQuery services.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	BigQueryServices.BigQueryServerStream<T> Container for reading data from streaming endpoints.
static interface	BigQueryServices.DatasetService An interface to get, create and delete Cloud BigQuery datasets and tables.
static interface	BigQueryServices.JobService An interface for the Cloud BigQuery load service.
static interface	BigQueryServices.StorageClient An interface representing a client object for making calls to the BigQuery Storage API.

Method Summary

Modifier and Type	Method and Description
BigQueryServices.DatasetService	getDatasetService(BigQueryOptions bqOptions) Returns a real, mock, or fake BigQueryServices.DatasetService.
BigQueryServices.JobService	getJobService(BigQueryOptions bqOptions) Returns a real, mock, or fake BigQueryServices.JobService.
BigQueryServices.StorageClient	getStorageClient(BigQueryOptions bqOptions) Returns a real, mock, or fake BigQueryServices.StorageClient.

Method Detail

getJobService

BigQueryServices.JobService getJobService(BigQueryOptions bqOptions)

Returns a real, mock, or fake BigQueryServices.JobService.

getDatasetService

BigQueryServices.DatasetService getDatasetService(BigQueryOptions bqOptions)

Returns a real, mock, or fake BigQueryServices.DatasetService.

getStorageClient

@Experimental(value=SOURCE_SINK)
BigQueryServices.StorageClient getStorageClient(BigQueryOptions bqOptions)
                                                                          throws java.io.IOException

Returns a real, mock, or fake BigQueryServices.StorageClient.

Throws:

java.io.IOException