Struct TableBatch 

pub struct TableBatch<M> {
    pub stream_name: StreamName,
    pub table_descriptor: Arc<TableDescriptor>,
    pub rows: Vec<M>,
}

Collection of rows targeting a specific BigQuery table for batch processing.

Encapsulates rows with their destination stream and schema metadata, enabling efficient batch operations and optimal parallelism distribution across multiple tables in concurrent append operations.

Fields

stream_name: StreamName

Target stream identifier for the append operations.

table_descriptor: Arc<TableDescriptor>

Schema descriptor for the target table.

rows: Vec<M>

Collection of rows to be appended to the table.

Implementations

impl<M> TableBatch<M>

pub fn new( stream_name: StreamName, table_descriptor: Arc<TableDescriptor>, rows: Vec<M>, ) -> Self

Creates a new table batch targeting the specified stream.

Combines rows with their destination metadata to form a complete batch ready for processing by append operations.

Trait Implementations

impl<M: Debug> Debug for TableBatch<M>

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

Formats the value using the given formatter.