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

Interface BigQueryServices

All Superinterfaces:

Serializable

All Known Implementing Classes:

BigQueryServicesImpl, FakeBigQueryServices

@Internal
public interface BigQueryServices
extends Serializable

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

Nested Class Summary

Nested Classes

Modifier and Type	Interface	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	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 Details

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 IOException

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

Throws:

IOException