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

Interface BigQueryServices.JobService

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

FakeJobService

Enclosing interface:

BigQueryServices

public static interface BigQueryServices.JobService
extends AutoCloseable

An interface for the Cloud BigQuery load service.

Method Summary

Modifier and Type	Method	Description
com.google.api.services.bigquery.model.JobStatistics	dryRunQuery(String projectId, com.google.api.services.bigquery.model.JobConfigurationQuery queryConfig, @Nullable String location)	Dry runs the query in the given project.
com.google.api.services.bigquery.model.Job	getJob(com.google.api.services.bigquery.model.JobReference jobRef)	Gets the specified Job by the given JobReference.
com.google.api.services.bigquery.model.Job	pollJob(com.google.api.services.bigquery.model.JobReference jobRef, int maxAttempts)	Waits for the job is Done, and returns the job.
void	startCopyJob(com.google.api.services.bigquery.model.JobReference jobRef, com.google.api.services.bigquery.model.JobConfigurationTableCopy copyConfig)	Start a BigQuery copy job.
void	startExtractJob(com.google.api.services.bigquery.model.JobReference jobRef, com.google.api.services.bigquery.model.JobConfigurationExtract extractConfig)	Start a BigQuery extract job.
void	startLoadJob(com.google.api.services.bigquery.model.JobReference jobRef, com.google.api.services.bigquery.model.JobConfigurationLoad loadConfig)	Start a BigQuery load job.
void	startLoadJob(com.google.api.services.bigquery.model.JobReference jobRef, com.google.api.services.bigquery.model.JobConfigurationLoad loadConfig, com.google.api.client.http.AbstractInputStreamContent streamContent)	Start a BigQuery load job with stream content.
void	startQueryJob(com.google.api.services.bigquery.model.JobReference jobRef, com.google.api.services.bigquery.model.JobConfigurationQuery query)	Start a BigQuery query job.

Methods inherited from interface java.lang.AutoCloseable

close

Method Details

startLoadJob

void startLoadJob(com.google.api.services.bigquery.model.JobReference jobRef,
 com.google.api.services.bigquery.model.JobConfigurationLoad loadConfig)
           throws InterruptedException,
IOException

Start a BigQuery load job.

Throws:

InterruptedException

IOException

startLoadJob

void startLoadJob(com.google.api.services.bigquery.model.JobReference jobRef,
 com.google.api.services.bigquery.model.JobConfigurationLoad loadConfig,
 com.google.api.client.http.AbstractInputStreamContent streamContent)
           throws InterruptedException,
IOException

Start a BigQuery load job with stream content.

Throws:

InterruptedException

IOException

startExtractJob

void startExtractJob(com.google.api.services.bigquery.model.JobReference jobRef,
 com.google.api.services.bigquery.model.JobConfigurationExtract extractConfig)
              throws InterruptedException,
IOException

Start a BigQuery extract job.

Throws:

InterruptedException

IOException

startQueryJob

void startQueryJob(com.google.api.services.bigquery.model.JobReference jobRef,
 com.google.api.services.bigquery.model.JobConfigurationQuery query)
            throws IOException,
InterruptedException

Start a BigQuery query job.

Throws:

IOException

InterruptedException

startCopyJob

void startCopyJob(com.google.api.services.bigquery.model.JobReference jobRef,
 com.google.api.services.bigquery.model.JobConfigurationTableCopy copyConfig)
           throws IOException,
InterruptedException

Start a BigQuery copy job.

Throws:

IOException

InterruptedException

pollJob

com.google.api.services.bigquery.model.Job pollJob(com.google.api.services.bigquery.model.JobReference jobRef,
 int maxAttempts)
                                            throws InterruptedException

Waits for the job is Done, and returns the job.

Returns null if the maxAttempts retries reached.

Throws:

InterruptedException

dryRunQuery

com.google.api.services.bigquery.model.JobStatistics dryRunQuery(String projectId,
 com.google.api.services.bigquery.model.JobConfigurationQuery queryConfig,
 @Nullable String location)
                                                          throws InterruptedException,
IOException

Dry runs the query in the given project.

Throws:

InterruptedException

IOException

getJob

com.google.api.services.bigquery.model.Job getJob(com.google.api.services.bigquery.model.JobReference jobRef)
                                           throws IOException,
InterruptedException

Gets the specified Job by the given JobReference.

Returns null if the job is not found.

Throws:

IOException

InterruptedException