Struct ZarrIoStats 

pub struct ZarrIoStats {
    pub metadata_bytes: AtomicU64,
    pub coord_bytes: AtomicU64,
    pub data_bytes: AtomicU64,
    pub disk_bytes: AtomicU64,
    pub coord_arrays: AtomicU64,
    pub data_arrays: AtomicU64,
    pub metadata_nanos: AtomicU64,
    pub coord_nanos: AtomicU64,
    pub data_nanos: AtomicU64,
}

I/O statistics collected during Zarr reads.

Uses atomic counters for thread-safety without locks, which is important for async/multi-threaded execution in DataFusion.

Fields

metadata_bytes: AtomicU64

coord_bytes: AtomicU64

data_bytes: AtomicU64

disk_bytes: AtomicU64

coord_arrays: AtomicU64

data_arrays: AtomicU64

metadata_nanos: AtomicU64

coord_nanos: AtomicU64

data_nanos: AtomicU64

Implementations

impl ZarrIoStats

pub fn new() -> Self

pub fn total_bytes(&self) -> u64

pub fn total_arrays(&self) -> u64

pub fn metadata_time(&self) -> Duration

pub fn coord_time(&self) -> Duration

pub fn data_time(&self) -> Duration

pub fn record_metadata(&self, bytes: u64, duration: Duration)

Record metadata read stats

pub fn record_coord(&self, bytes: u64, duration: Duration)

Record coordinate array read stats

pub fn record_data(&self, bytes: u64, duration: Duration)

Record data variable read stats

pub fn record_disk_read(&self, bytes: u64)

Record disk bytes read (actual I/O)

pub fn total_disk_bytes(&self) -> u64

Get total disk bytes read

Trait Implementations

impl Debug for ZarrIoStats

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

Formats the value using the given formatter.

impl Default for ZarrIoStats

fn default() -> ZarrIoStats

Returns the “default value” for a type.