Struct ParquetEncoder 

pub struct ParquetEncoder<C = Uncompressed> { /* private fields */ }

Encodes a window into a parquet file held in memory.

The arrow schema is derived from R itself (not sampled from values, so an empty slice still produces a valid zero-row file), which is why DeserializeOwned is required alongside Serialize.

The default compression policy is Uncompressed. Select zstd and its level in the encoder type:

use meathook::{ParquetEncoder, Zstd};

let uncompressed = ParquetEncoder::default();
let zstd_1 = ParquetEncoder::<Zstd>::new();
let zstd_3 = ParquetEncoder::<Zstd<3>>::new();

Implementations

impl<C: ParquetCompression> ParquetEncoder<C>

pub const fn new() -> Self

Creates an encoder using the compression policy C.

Trait Implementations

impl<C: Clone> Clone for ParquetEncoder<C>

fn clone(&self) -> ParquetEncoder<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Copy> Copy for ParquetEncoder<C>

impl<C: Debug> Debug for ParquetEncoder<C>

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

Formats the value using the given formatter.

impl Default for ParquetEncoder

Available on crate feature parquet only.

fn default() -> Self

Returns the “default value” for a type.

impl<C: ParquetCompression> Encoder for ParquetEncoder<C>

Available on crate feature parquet only.

fn encode<R: Serialize + DeserializeOwned>( &self, records: &[R], ) -> Result<Vec<u8>, Self::Error>

Errors

Returns an error if schema derivation, record batch construction, or parquet writing fails.

const EXT: &'static str = "parquet"

File extension (no leading dot) for files this encoder produces, e.g. "parquet".

type Error = ParquetEncodeError

Error produced when encoding fails.