Struct PendingWriter 

pub struct PendingWriter<F> { /* private fields */ }

A writer for a pending stream.

In a pending stream, records are buffered in a pending state until you commit the stream. When you commit a stream, all of the pending data becomes available for reading atomically. Use this type for batch workloads, as an alternative to BigQuery load jobs.

Implementations

impl<F> PendingWriter<F>

where F: DataFormat,

pub fn write_stream(&self) -> &str

Returns the full resource name of the underlying write stream.

pub fn append(&self, rows: F::Rows) -> AppendWithOffset

Appends rows to the pending stream.

pub async fn finalize(&self) -> Result<FinalizeWriteStreamResponse>

Finalizes the pending stream, preventing further writes.

pub async fn commit( &self, ) -> Result<BatchCommitWriteStreamsResponse, CommitError>

Commits the pending stream to the table.

The stream must be finalized via finalize before calling commit.

Trait Implementations

impl<F: Debug> Debug for PendingWriter<F>

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

Formats the value using the given formatter.

impl<F> HasStream for PendingWriter<F>

type Stream = PendingStream

The stream type marker corresponding to this writer.