Struct WriteAccounting 

pub struct WriteAccounting { /* private fields */ }

A point-in-time view of writer data accounting.

Row counts are logical rows. Byte counts are the estimated raw serialized data-frame lengths used for bounded buffering, so they are independent of both the selected compression codec and the selected encoding policy: a column that Zstandard or an adaptive transform shrinks is still counted at its raw size. They describe how much the writer is holding and has accepted, not how much it wrote. WriteSummary::bytes_written is the actual final file length, including the prologue and schema frame.

Every count here belongs to one writer session. A writer from crate::Writer::open starts them all at zero, whatever the file already contains.

Implementations

impl WriteAccounting

pub fn buffered_rows(&self) -> u64

Rows currently held in the in-memory block buffer.

pub fn buffered_bytes(&self) -> u64

Estimated raw bytes currently held in the in-memory block buffer.

pub fn published_rows(&self) -> u64

Rows whose complete frames have been written to the sink.

pub fn published_bytes(&self) -> u64

Estimated raw bytes represented by published data blocks.

pub fn durable_rows(&self) -> u64

Rows covered by a completed sink synchronization.

pub fn durable_bytes(&self) -> u64

Estimated raw bytes covered by a completed sink synchronization.

pub fn total_rows(&self) -> u64

All rows accepted by the writer, whether buffered or published.

pub fn total_bytes(&self) -> u64

All estimated raw bytes accepted by the writer, whether buffered or published.

Trait Implementations

impl Clone for WriteAccounting

fn clone(&self) -> WriteAccounting

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for WriteAccounting

impl Debug for WriteAccounting

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

Formats the value using the given formatter.

impl Default for WriteAccounting

fn default() -> WriteAccounting

Returns the “default value” for a type.

impl Eq for WriteAccounting

impl PartialEq for WriteAccounting

fn eq(&self, other: &WriteAccounting) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for WriteAccounting