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

Interface BigQueryServices.JobService

All Superinterfaces:

java.lang.AutoCloseable

All Known Implementing Classes:

FakeJobService

Enclosing interface:

BigQueryServices

public static interface BigQueryServices.JobService
extends java.lang.AutoCloseable

An interface for the Cloud BigQuery load service.

Method Summary

Modifier and Type	Method and Description
JobStatistics	dryRunQuery(java.lang.String projectId, JobConfigurationQuery queryConfig, @Nullable java.lang.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 Detail

startLoadJob

void startLoadJob(JobReference jobRef,
                  JobConfigurationLoad loadConfig)
           throws java.lang.InterruptedException,
                  java.io.IOException

Start a BigQuery load job.

Throws:

java.lang.InterruptedException

java.io.IOException

startLoadJob

void startLoadJob(JobReference jobRef,
                  JobConfigurationLoad loadConfig,
                  com.google.api.client.http.AbstractInputStreamContent streamContent)
           throws java.lang.InterruptedException,
                  java.io.IOException

Start a BigQuery load job with stream content.

Throws:

java.lang.InterruptedException

java.io.IOException

startExtractJob

void startExtractJob(JobReference jobRef,
                     JobConfigurationExtract extractConfig)
              throws java.lang.InterruptedException,
                     java.io.IOException

Start a BigQuery extract job.

Throws:

java.lang.InterruptedException

java.io.IOException

startQueryJob

void startQueryJob(JobReference jobRef,
                   JobConfigurationQuery query)
            throws java.io.IOException,
                   java.lang.InterruptedException

Start a BigQuery query job.

Throws:

java.io.IOException

java.lang.InterruptedException

startCopyJob

void startCopyJob(JobReference jobRef,
                  JobConfigurationTableCopy copyConfig)
           throws java.io.IOException,
                  java.lang.InterruptedException

Start a BigQuery copy job.

Throws:

java.io.IOException

java.lang.InterruptedException

pollJob

Job pollJob(JobReference jobRef,
            int maxAttempts)
     throws java.lang.InterruptedException

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

Returns null if the maxAttempts retries reached.

Throws:

java.lang.InterruptedException

dryRunQuery

JobStatistics dryRunQuery(java.lang.String projectId,
                          JobConfigurationQuery queryConfig,
                          @Nullable java.lang.String location)
                   throws java.lang.InterruptedException,
                          java.io.IOException

Dry runs the query in the given project.

Throws:

java.lang.InterruptedException

java.io.IOException

getJob

Job getJob(JobReference jobRef)
    throws java.io.IOException,
           java.lang.InterruptedException

Gets the specified Job by the given JobReference.

Returns null if the job is not found.

Throws:

java.io.IOException

java.lang.InterruptedException