@Internal public class FakeJobService extends java.lang.Object implements BigQueryServices.JobService, java.io.Serializable
Constructor and Description |
---|
FakeJobService() |
FakeJobService(int numFailures) |
Modifier and Type | Method and Description |
---|---|
com.google.api.services.bigquery.model.JobStatistics |
dryRunQuery(java.lang.String projectId,
com.google.api.services.bigquery.model.JobConfigurationQuery query,
java.lang.String location)
Dry runs the query in the given project.
|
void |
expectDryRunQuery(java.lang.String projectId,
java.lang.String query,
com.google.api.services.bigquery.model.JobStatistics result) |
java.util.Collection<com.google.api.services.bigquery.model.Job> |
getAllJobs() |
com.google.api.services.bigquery.model.Job |
getJob(com.google.api.services.bigquery.model.JobReference jobRef)
Gets the specified
Job by the given JobReference . |
int |
getNumExtractJobCalls() |
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 |
setNumFailuresExpected(int numFailuresExpected) |
static void |
setUp() |
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 |
startQueryJob(com.google.api.services.bigquery.model.JobReference jobRef,
com.google.api.services.bigquery.model.JobConfigurationQuery query)
Start a BigQuery query job.
|
public FakeJobService()
public FakeJobService(int numFailures)
public void setNumFailuresExpected(int numFailuresExpected)
public static void setUp()
public void startLoadJob(com.google.api.services.bigquery.model.JobReference jobRef, com.google.api.services.bigquery.model.JobConfigurationLoad loadConfig) throws java.io.IOException
BigQueryServices.JobService
startLoadJob
in interface BigQueryServices.JobService
java.io.IOException
public void startExtractJob(com.google.api.services.bigquery.model.JobReference jobRef, com.google.api.services.bigquery.model.JobConfigurationExtract extractConfig) throws java.io.IOException
BigQueryServices.JobService
startExtractJob
in interface BigQueryServices.JobService
java.io.IOException
public int getNumExtractJobCalls()
public void startQueryJob(com.google.api.services.bigquery.model.JobReference jobRef, com.google.api.services.bigquery.model.JobConfigurationQuery query)
BigQueryServices.JobService
startQueryJob
in interface BigQueryServices.JobService
public void startCopyJob(com.google.api.services.bigquery.model.JobReference jobRef, com.google.api.services.bigquery.model.JobConfigurationTableCopy copyConfig) throws java.io.IOException
BigQueryServices.JobService
startCopyJob
in interface BigQueryServices.JobService
java.io.IOException
public com.google.api.services.bigquery.model.Job pollJob(com.google.api.services.bigquery.model.JobReference jobRef, int maxAttempts) throws java.lang.InterruptedException
BigQueryServices.JobService
Returns null if the maxAttempts
retries reached.
pollJob
in interface BigQueryServices.JobService
java.lang.InterruptedException
public void expectDryRunQuery(java.lang.String projectId, java.lang.String query, com.google.api.services.bigquery.model.JobStatistics result)
public com.google.api.services.bigquery.model.JobStatistics dryRunQuery(java.lang.String projectId, com.google.api.services.bigquery.model.JobConfigurationQuery query, java.lang.String location)
BigQueryServices.JobService
dryRunQuery
in interface BigQueryServices.JobService
public java.util.Collection<com.google.api.services.bigquery.model.Job> getAllJobs()
public com.google.api.services.bigquery.model.Job getJob(com.google.api.services.bigquery.model.JobReference jobRef)
BigQueryServices.JobService
Job
by the given JobReference
.
Returns null if the job is not found.
getJob
in interface BigQueryServices.JobService