Struct BatchWriter 

pub struct BatchWriter { /* private fields */ }

Implementations

impl BatchWriter

pub fn insert( &mut self, table_name: &str, values: Vec<CellValue>, ) -> Result<&mut Self, String>

pub fn pending_count(&self) -> usize

pub async fn flush(&mut self) -> DataFusionResult<u64>

Flush pending rows to ingest and return the post-ingest consistency token.

pub async fn flush_with_receipt( &mut self, ) -> DataFusionResult<Option<BatchReceipt>>

Flush pending rows to ingest and return metadata for the persisted batch.

pub fn prepare_flush(&mut self) -> DataFusionResult<Option<PreparedBatch>>

pub fn stage_flush( &self, prepared: &PreparedBatch, batch: &mut StoreWriteBatch, ) -> DataFusionResult<()>

pub fn mark_flush_persisted( &self, prepared: PreparedBatch, sequence_number: u64, ) -> BatchReceipt

pub fn mark_flush_failed(&self, prepared: PreparedBatch)

Trait Implementations

impl Debug for BatchWriter

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

Formats the value using the given formatter.

impl StoreBatchUpload for BatchWriter

type Prepared = PreparedBatch

type Receipt = BatchReceipt

type Error = DataFusionError

fn stage_upload( &self, prepared: &Self::Prepared, batch: &mut StoreWriteBatch, ) -> Result<(), Self::Error>

fn commit_error(&self, error: ClientError) -> Self::Error

fn mark_upload_persisted<'a>( &'a self, prepared: Self::Prepared, sequence_number: u64, ) -> BoxFuture<'a, Self::Receipt>

where Self: Sync + 'a, Self::Prepared: 'a,

fn mark_upload_failed<'a>( &'a self, prepared: Self::Prepared, _error: String, ) -> BoxFuture<'a, ()>

where Self: Sync + 'a, Self::Prepared: 'a,

fn commit_upload<'a>( &'a self, client: &'a StoreClient, prepared: Self::Prepared, ) -> Pin<Box<dyn Future<Output = Result<Self::Receipt, Self::Error>> + Send + 'a>>

where Self: Sized + Sync + 'a, Self::Prepared: 'a, Self::Receipt: 'a, Self::Error: 'a,