Struct iceberg_rust_spec::spec::manifest::ManifestWriter

pub struct ManifestWriter<'a, W: Write>(/* private fields */);

A writer for manifest entries

Implementations

impl<'a, W: Write> ManifestWriter<'a, W>

pub fn new( writer: W, schema: &'a AvroSchema, table_metadata: &TableMetadata, branch: Option<&str> ) -> Result<Self, Error>

pub fn into_inner(self) -> Result<W, Error>

Methods from Deref<Target = AvroWriter<'a, W>>

pub fn schema(&self) -> &'a Schema

Get a reference to the Schema associated to a Writer.

pub fn append<T>(&mut self, value: T) -> Result<usize, Error>

where T: Into<Value>,

Append a compatible value (implementing the ToAvro trait) to a Writer, also performing schema validation.

Return the number of bytes written (it might be 0, see below).

NOTE This function is not guaranteed to perform any actual write, since it relies on internal buffering for performance reasons. If you want to be sure the value has been written, then call flush.

pub fn append_value_ref(&mut self, value: &Value) -> Result<usize, Error>

Append a compatible value to a Writer, also performing schema validation.

Return the number of bytes written (it might be 0, see below).

NOTE This function is not guaranteed to perform any actual write, since it relies on internal buffering for performance reasons. If you want to be sure the value has been written, then call flush.

pub fn append_ser<S>(&mut self, value: S) -> Result<usize, Error>

where S: Serialize,

Append anything implementing the Serialize trait to a Writer for serde compatibility, also performing schema validation.

Return the number of bytes written.

NOTE This function is not guaranteed to perform any actual write, since it relies on internal buffering for performance reasons. If you want to be sure the value has been written, then call flush.

pub fn extend<I, T>(&mut self, values: I) -> Result<usize, Error>

where T: Into<Value>, I: IntoIterator<Item = T>,

Extend a Writer with an Iterator of compatible values (implementing the ToAvro trait), also performing schema validation.

Return the number of bytes written.

NOTE This function forces the written data to be flushed (an implicit call to flush is performed).

pub fn extend_ser<I, T>(&mut self, values: I) -> Result<usize, Error>

where T: Serialize, I: IntoIterator<Item = T>,

Extend a Writer with an Iterator of anything implementing the Serialize trait for serde compatibility, also performing schema validation.

Return the number of bytes written.

NOTE This function forces the written data to be flushed (an implicit call to flush is performed).

pub fn extend_from_slice(&mut self, values: &[Value]) -> Result<usize, Error>

Extend a Writer by appending each Value from a slice, while also performing schema validation on each value appended.

Return the number of bytes written.

NOTE This function forces the written data to be flushed (an implicit call to flush is performed).

pub fn flush(&mut self) -> Result<usize, Error>

Flush the content appended to a Writer. Call this function to make sure all the content has been written before releasing the Writer.

Return the number of bytes written.

pub fn add_user_metadata<T>( &mut self, key: String, value: T ) -> Result<(), Error>

where T: AsRef<[u8]>,

Adds custom metadata to the file. This method could be used only before adding the first record to the writer.

Trait Implementations

impl<'a, W: Write> Deref for ManifestWriter<'a, W>

type Target = Writer<'a, W>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<'a, W: Write> DerefMut for ManifestWriter<'a, W>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.