Struct BigqueryJobClient 

pub struct BigqueryJobClient { /* private fields */ }

Implementations

impl BigqueryJobClient

pub fn new(inner: Arc<BigqueryClient>) -> Self

pub async fn create(&self, metadata: &Job) -> Result<Job, Error>

https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs/create

use google_cloud_bigquery::http::bigquery_job_client::BigqueryJobClient;
use google_cloud_bigquery::http::error::Error;
use google_cloud_bigquery::http::job::{CreateDisposition, Job, JobConfiguration, JobConfigurationSourceTable, JobConfigurationTableCopy, JobReference, JobState, JobType, OperationType, WriteDisposition};
use google_cloud_bigquery::http::table::TableReference;

async fn run(client: BigqueryJobClient)  {
    let job = Job {
        job_reference: JobReference {
            project_id: "project".to_string(),
            job_id: "job".to_string(),
            location: Some("asia-northeast1".to_string()),
        },
        configuration: JobConfiguration {
            job: JobType::Copy(JobConfigurationTableCopy {
                source_table: JobConfigurationSourceTable::SourceTable(TableReference {
                    project_id: "project".to_string(),
                    dataset_id: "dataset".to_string(),
                    table_id: "source_table".to_string(),
                }),
                destination_table: TableReference {
                    project_id: "project".to_string(),
                    dataset_id: "dataset".to_string(),
                    table_id: "destination_table".to_string(),
                },
                create_disposition: Some(CreateDisposition::CreateIfNeeded),
                write_disposition: Some(WriteDisposition::WriteTruncate),
                operation_type: Some(OperationType::Copy),
                ..Default::default()
            }),
            ..Default::default()
        },
        ..Default::default()
    };
    let created = client.create(&job).await.unwrap();
    assert!(created.status.errors.is_none());
    assert!(created.status.error_result.is_none());
    assert!(created.status.state == JobState::Running || created.status.state == JobState::Done);
}

pub async fn delete(&self, project_id: &str, job_id: &str) -> Result<(), Error>

https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs/delete

pub async fn get( &self, project_id: &str, job_id: &str, data: &GetJobRequest, ) -> Result<Job, Error>

https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs/get

pub async fn cancel( &self, project_id: &str, job_id: &str, data: &CancelJobRequest, ) -> Result<CancelJobResponse, Error>

https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs/cancel

use google_cloud_bigquery::http::bigquery_job_client::BigqueryJobClient;
use google_cloud_bigquery::http::error::Error;
use google_cloud_bigquery::http::job::cancel::CancelJobRequest;
use google_cloud_bigquery::http::job::{Job, JobReference, JobState};

 async fn run(client: BigqueryJobClient, job: JobReference) {
    let request = CancelJobRequest {
        location: job.location,
    };
    let cancelled = client.cancel(&job.project_id, &job.job_id, &request).await.unwrap();
 }

pub async fn query( &self, project_id: &str, data: &QueryRequest, ) -> Result<QueryResponse, Error>

https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs/query

pub async fn get_query_results( &self, project_id: &str, job_id: &str, data: &GetQueryResultsRequest, ) -> Result<GetQueryResultsResponse, Error>

https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs/get_query_results

pub async fn list( &self, project_id: &str, req: &ListJobsRequest, ) -> Result<Vec<JobOverview>, Error>

https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs/list

Trait Implementations

impl Clone for BigqueryJobClient

fn clone(&self) -> BigqueryJobClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BigqueryJobClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.