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

Interface BigQueryServices

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

BigQueryServicesImpl, FakeBigQueryServices

@Internal
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.
static interface	BigQueryServices.StreamAppendClient An interface for appending records to a Storage API write stream.
static interface	BigQueryServices.WriteStreamService An interface to get, create and flush Cloud BigQuery STORAGE API write streams.

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.
BigQueryServices.WriteStreamService	getWriteStreamService(BigQueryOptions bqOptions) Returns a real, mock, or fake BigQueryServices.WriteStreamService.

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.

getWriteStreamService

BigQueryServices.WriteStreamService getWriteStreamService(BigQueryOptions bqOptions)

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

getStorageClient

BigQueryServices.StorageClient getStorageClient(BigQueryOptions bqOptions)
                                         throws java.io.IOException

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

Throws:

java.io.IOException