Struct Parquet 

pub struct Parquet {
    pub compression: Compression,
}

Parquet file format. Carries encoder knobs; decoding needs none.

Fields

compression: Compression

Compression codec for column chunks.

Implementations

impl Parquet

pub fn new(compression: Compression) -> Self

Build a Parquet codec.

Trait Implementations

impl Clone for Parquet

fn clone(&self) -> Parquet

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Parquet

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

Formats the value using the given formatter.

impl Default for Parquet

fn default() -> Parquet

Returns the “default value” for a type.

impl FormatRead for Parquet

fn read<'life0, 'async_trait>( &'life0 self, reader: Box<dyn FileReader>, ) -> Pin<Box<dyn Future<Output = Result<BatchStream, TransferredError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read one open file handle into a stream of Arrow batches.

impl FormatWrite for Parquet

fn file_extension(&self) -> &'static str

File extension for written parts, no dot (e.g. "parquet").

fn write<'life0, 'async_trait>( &'life0 self, writer: Box<dyn FileWriter>, batches: BatchStream, ) -> Pin<Box<dyn Future<Output = Result<u64, TransferredError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Write all batches into one open sink. Returns the row count written.