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

Methods inherited from interface java.lang.AutoCloseable

close

Method Details

startLoadJob

void startLoadJob(JobReference jobRef,
 JobConfigurationLoad loadConfig)
           throws InterruptedException,
IOException

Start a BigQuery load job.

Throws:

InterruptedException

IOException

startLoadJob

void startLoadJob(JobReference jobRef,
 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(JobReference jobRef,
 JobConfigurationExtract extractConfig)
              throws InterruptedException,
IOException

Start a BigQuery extract job.

Throws:

InterruptedException

IOException

startQueryJob

void startQueryJob(JobReference jobRef,
 JobConfigurationQuery query)
            throws IOException,
InterruptedException

Start a BigQuery query job.

Throws:

IOException

InterruptedException

startCopyJob

void startCopyJob(JobReference jobRef,
 JobConfigurationTableCopy copyConfig)
           throws IOException,
InterruptedException

Start a BigQuery copy job.

Throws:

IOException

InterruptedException

pollJob

Job pollJob(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

JobStatistics dryRunQuery(String projectId,
 JobConfigurationQuery queryConfig,
 @Nullable String location)
                   throws InterruptedException,
IOException

Dry runs the query in the given project.

Throws:

InterruptedException

IOException

getJob

Job getJob(JobReference jobRef)
    throws IOException,
InterruptedException

Gets the specified Job by the given JobReference.

Returns null if the job is not found.

Throws:

IOException

InterruptedException