Struct WriterBuilder 

pub struct WriterBuilder { /* private fields */ }

A builder to create a stream writer

Implementations

impl WriterBuilder

pub fn default<T: Into<String>>(self, table: T) -> Result<DefaultWriter>

Create a writer for the default stream for the given table.

Example

let writer = client
    .arrow(schema())
    .default("projects/my-project/datasets/my-dataset/tables/my-table")?;

use google_cloud_bigquery::model::ArrowSchema;
fn schema() -> ArrowSchema {
  todo!("Define your table's schema...")
}

pub async fn pending<T: Into<String>>(self, table: T) -> Result<PendingWriter>

Creates a pending writer for the given table.

Example

let writer = client
    .arrow(schema())
    .pending("projects/my-project/datasets/my-dataset/tables/my-table")
    .await?;

use google_cloud_bigquery::model::ArrowSchema;
fn schema() -> ArrowSchema {
  todo!("Define your table's schema...")
}

pub async fn committed<T: Into<String>>( self, table: T, ) -> Result<CommittedWriter>

Creates a committed writer for the given table.

Example

let writer = client
    .arrow(schema())
    .committed("projects/my-project/datasets/my-dataset/tables/my-table")
    .await?;

use google_cloud_bigquery::model::ArrowSchema;
fn schema() -> ArrowSchema {
  todo!("Define your table's schema...")
}

pub async fn buffered<T: Into<String>>(self, table: T) -> Result<BufferedWriter>

Creates a buffered writer for the given table.

Example

let writer = client
    .arrow(schema())
    .buffered("projects/my-project/datasets/my-dataset/tables/my-table")
    .await?;

use google_cloud_bigquery::model::ArrowSchema;
fn schema() -> ArrowSchema {
  todo!("Define your table's schema...")
}

pub async fn attach<U: Writer, S: Into<String>>( self, write_stream: S, ) -> Result<U, AttachError>

Attaches the builder to an existing stream.

Example

use google_cloud_bigquery::write::arrow::CommittedWriter;
let writer: CommittedWriter = client
    .arrow(schema())
    .attach("projects/my-project/datasets/my_dataset/tables/my_table/streams/my_stream")
    .await?;

Trait Implementations

impl Clone for WriterBuilder

fn clone(&self) -> WriterBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WriterBuilder

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

Formats the value using the given formatter.