Struct Delta 

pub struct Delta<D> {
    pub inner: D,
}

Fields

inner: D

Implementations

impl Delta<DeltaImmutable>

pub async fn open( storage: Arc<dyn Storage>, path: Arc<str>, cache: Option<Arc<DeltaCache>>, ) -> Result<Self>

Opens a committed delta file from the given storage.

pub fn array_meta(&self, name: &str) -> Option<&ArrayMeta>

Returns the array metadata for name if present and not deleted.

pub async fn read_raw_chunk( &self, name: &str, coord: &[u32], ) -> Result<Option<Bytes>>

Returns the raw (uncompressed) bytes for the chunk at coord, or None if this delta does not have that chunk.

impl Delta<DeltaMutable>

pub fn new( codec: Arc<dyn CompressionCodec>, block_target_size: usize, delta_index: u32, ) -> Self

pub fn define_array( &mut self, name: impl Into<String>, dtype: DType, shape: Vec<usize>, dimension_names: Vec<String>, chunk_shape: Option<Vec<usize>>, fill_value: Option<FillValue>, ) -> Result<()>

pub fn array_meta(&self, name: &str) -> Option<&ArrayMeta>

pub fn write_raw_chunk( &mut self, name: &str, coord: Vec<u32>, raw: &[u8], ) -> Result<()>

Allocates chunk bytes and records the chunk address in the array meta.

pub fn array_meta_mut(&mut self, name: &str) -> Option<&mut ArrayMeta>

Returns a mutable reference to the ArrayMeta for name, if present.

pub fn upsert_array_meta(&mut self, meta: ArrayMeta)

Inserts or replaces the ArrayMeta for meta.name.

pub fn mark_deleted(&mut self, meta: ArrayMeta)

Stamps meta as deleted, clears its chunks, and upserts it.

pub fn intern_attr_key(&mut self, key: &str) -> usize

Interns key into the attribute key dictionary, returning its index.

pub fn intern_attr_value(&mut self, value: AttributeValue) -> usize

Interns value into the attribute value dictionary, returning its index.

pub fn read_raw_chunk(&self, name: &str, coord: &[u32]) -> Option<Bytes>

Reads raw (uncompressed) chunk bytes previously written into this mutable delta. Returns None if the array or coord is not present.

pub async fn commit( self, storage: Arc<dyn Storage>, path: Arc<str>, cache: Option<Arc<DeltaCache>>, base_file_hint: impl Into<String>, ) -> Result<Delta<DeltaImmutable>>

Commits this delta: compresses all buffered blocks, serializes the footer, and writes the complete delta bytes to storage.