com.google.cloud.bigquery

Class Job

java.lang.Object

com.google.cloud.bigquery.JobInfo

com.google.cloud.bigquery.Job

All Implemented Interfaces:

Serializable

public class Job
extends JobInfo

A Google BigQuery Job.

Objects of this class are immutable. To get a Job object with the most recent information use reload(com.google.cloud.bigquery.BigQuery.JobOption...). Job adds a layer of service-related functionality over JobInfo.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Job.Builder A builder for Job objects.

Nested classes/interfaces inherited from class com.google.cloud.bigquery.JobInfo

JobInfo.CreateDisposition, JobInfo.SchemaUpdateOption, JobInfo.WriteDisposition

Method Summary

Modifier and Type	Method and Description
boolean	cancel() Sends a job cancel request.
boolean	equals(Object obj)
boolean	exists() Checks if this job exists.
BigQuery	getBigquery() Returns the job's BigQuery object used to issue requests.
int	hashCode()
boolean	isDone() Checks if this job has completed its execution, either failing or succeeding.
Job	reload(BigQuery.JobOption... options) Fetches current job's latest information.
Job.Builder	toBuilder() Returns a builder for the job object.
Job	waitFor(WaitForOption... waitOptions) Blocks until this job completes its execution, either failing or succeeding.

Methods inherited from class com.google.cloud.bigquery.JobInfo

getConfiguration, getEtag, getGeneratedId, getJobId, getSelfLink, getStatistics, getStatus, getUserEmail, newBuilder, of, of, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

exists

public boolean exists()

Checks if this job exists.

Example of checking that a job exists.

 
 if (!job.exists()) {
   // job doesn't exist
 }
 

Returns:

true if this job exists, false otherwise

Throws:

BigQueryException - upon failure

isDone

public boolean isDone()

Checks if this job has completed its execution, either failing or succeeding. If the job does not exist this method returns true.

Example of waiting for a job until it reports that it is done.

 
 while (!job.isDone()) {
   Thread.sleep(1000L);
 }
 

Returns:

true if this job is in JobStatus.State.DONE state or if it does not exist, false if the state is not JobStatus.State.DONE

Throws:

BigQueryException - upon failure

waitFor

public Job waitFor(WaitForOption... waitOptions)
            throws InterruptedException,
                   TimeoutException

Blocks until this job completes its execution, either failing or succeeding. This method returns current job's latest information. If the job no longer exists, this method returns null. By default, the job status is checked every 500 milliseconds, to configure this value use WaitForOption.checkEvery(long, TimeUnit). Use WaitForOption.timeout(long, TimeUnit) to set the maximum time to wait.

Example usage of waitFor().

 
 Job completedJob = job.waitFor();
 if (completedJob == null) {
   // job no longer exists
 } else if (completedJob.getStatus().getError() != null) {
   // job failed, handle error
 } else {
   // job completed successfully
 }
 

Example usage of waitFor() with checking period and timeout.

 
 Job completedJob =
     job.waitFor(
         WaitForOption.checkEvery(1, TimeUnit.SECONDS),
         WaitForOption.timeout(60, TimeUnit.SECONDS));
 if (completedJob == null) {
   // job no longer exists
 } else if (completedJob.getStatus().getError() != null) {
   // job failed, handle error
 } else {
   // job completed successfully
 }
 

Parameters:

waitOptions - options to configure checking period and timeout

Throws:

BigQueryException - upon failure

InterruptedException - if the current thread gets interrupted while waiting for the job to complete

TimeoutException - if the timeout provided with WaitForOption.timeout(long, TimeUnit) is exceeded. If no such option is provided this exception is never thrown.

reload

public Job reload(BigQuery.JobOption... options)

Fetches current job's latest information. Returns null if the job does not exist.

Example of reloading all fields until job status is DONE.

 
 while (job.getStatus().getState() != JobStatus.State.DONE) {
   Thread.sleep(1000L);
   job = job.reload();
 }
 

Example of reloading status field until job status is DONE.

 
 while (job.getStatus().getState() != JobStatus.State.DONE) {
   Thread.sleep(1000L);
   job = job.reload(BigQuery.JobOption.fields(BigQuery.JobField.STATUS));
 }
 

Parameters:

options - job options

Returns:

a Job object with latest information or null if not found

Throws:

BigQueryException - upon failure

cancel

public boolean cancel()

Sends a job cancel request.

Example of cancelling a job.

 
 if (job.cancel()) {
   return true; // job successfully cancelled
 } else {
   // job not found
 }
 

Returns:

true if cancel request was sent successfully, false if job was not found

Throws:

BigQueryException - upon failure

getBigquery

public BigQuery getBigquery()

Returns the job's BigQuery object used to issue requests.

toBuilder

public Job.Builder toBuilder()

Description copied from class: JobInfo

Returns a builder for the job object.

Overrides:

toBuilder in class JobInfo

equals

public final boolean equals(Object obj)

Overrides:

equals in class JobInfo

hashCode

public final int hashCode()

Overrides:

hashCode in class JobInfo