Struct PendingTableInsert 

pub struct PendingTableInsert {
    pub namespace: String,
    pub table: String,
    pub rows: Vec<Params>,
    pub batches: Vec<(usize, RecordBatch)>,
}

Fields

namespace: String

table: String

rows: Vec<Params>

batches: Vec<(usize, RecordBatch)>

Implementations

impl PendingTableInsert

pub fn new(namespace: String, table: String) -> Self

pub fn add_row(&mut self, params: Params)

pub fn add_rows<I: IntoIterator<Item = Params>>(&mut self, iter: I)

pub fn add_batch(&mut self, batch: RecordBatch)

Trait Implementations

impl Clone for PendingTableInsert

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingTableInsert

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

Formats the value using the given formatter.