pub struct ConnectedBulkWriter<'client> { /* private fields */ }Expand description
Bulk writer created from a ConnectedMssqlClient.
This wrapper keeps the compatible Tiberius client and transport types out of
downstream signatures while exposing the same write and finish operations as
BulkWriter.
Implementations§
Source§impl ConnectedBulkWriter<'_>
impl ConnectedBulkWriter<'_>
Sourcepub async fn write_batch(&mut self, batch: &RecordBatch) -> Result<WriteStats>
pub async fn write_batch(&mut self, batch: &RecordBatch) -> Result<WriteStats>
Writes one Arrow record batch.
Sourcepub async fn finish(self) -> Result<WriteStats>
pub async fn finish(self) -> Result<WriteStats>
Finalizes the bulk writer and returns cumulative write statistics.
Trait Implementations§
Auto Trait Implementations§
impl<'client> !UnwindSafe for ConnectedBulkWriter<'client>
impl<'client> Freeze for ConnectedBulkWriter<'client>
impl<'client> RefUnwindSafe for ConnectedBulkWriter<'client>
impl<'client> Send for ConnectedBulkWriter<'client>
impl<'client> Sync for ConnectedBulkWriter<'client>
impl<'client> Unpin for ConnectedBulkWriter<'client>
impl<'client> UnsafeUnpin for ConnectedBulkWriter<'client>
Blanket Implementations§
impl<T> Allocation for T
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more