stream_writer

Stable type · Streaming writer

Tier: stable · Kind: type · Topic: Streaming writer

Python	Julia	Rust
not exported	`ZarrWriter`	`ZarrStreamWriter`

Python

Python does not export this type.

Julia

struct ZarrWriter <: Writer
ZarrWriter()

The zarr streaming writer (sharded Zarr v3). Registered :active in [WRITER_REGISTRY]; the write mirror of [ZarrReader]. Its handle and the streaming contract live in zarr_stream.jl.

Source

Rust

pub struct ZarrStreamWriter<S> {
    /* private fields */
}

impl<S> ZarrStreamWriter<S> { pub fn create(store: Arc<S>, base_url: &str, schema: StreamSchema, role: Role, region: Region) -> Result<Self> }

impl<S> ZarrStreamWriter<S> { pub fn join(store: Arc<S>, base_url: &str, role: Role, region: Region) -> Result<Self> }

impl<S> ZarrStreamWriter<S> { pub fn resume(store: Arc<S>, base_url: &str, role: Role, region: Region, at: Option<f64>) -> Result<Self> }

impl<S> ZarrStreamWriter<S> { pub fn write_record(&mut self, t: f64, arrays: &RecordArrays<'_>) -> Result<u64> }

impl<S> ZarrStreamWriter<S> { pub fn write_record_at(&mut self, index: u64, t: f64, arrays: &RecordArrays<'_>) -> Result<()> }

impl<S> ZarrStreamWriter<S> { pub fn write_static(&mut self, name: &str, array: TypedArray<'_>) -> Result<()> }

impl<S> ZarrStreamWriter<S> { pub fn write_blob(&mut self, scope: BlobScope, key: &str, bytes: &[u8]) -> Result<()> }

impl<S> ZarrStreamWriter<S> { pub fn flush(&mut self) -> Result<CommitToken> }

impl<S> ZarrStreamWriter<S> { pub fn commit(&mut self, tokens: &[CommitToken]) -> Result<CommitReceipt> }

impl<S> ZarrStreamWriter<S> { pub fn invalidate(&mut self, indices: &[u64]) -> Result<()> }

impl<S> ZarrStreamWriter<S> { pub fn invalidate_statics(&mut self, names: &[&str]) -> Result<()> }

impl<S> ZarrStreamWriter<S> { pub fn close(self, tokens: &[CommitToken]) -> Result<Option<Value>> }

impl<S> ZarrStreamWriter<S> { pub fn region(&self) -> Region }

impl<S> ZarrStreamWriter<S> { pub fn fingerprint(&self) -> &str }

The streaming writer handle (spec/writer.md). See the module docs.

Source · Rust docs