A FallibleStreamingIterator that consumes EncodedPage and yields CompressedPage holding a reusable buffer (Vec<u8>) for compression.

DynIter is an implementation of a single-threaded, dynamically-typed iterator.

An interface to write a parquet file asynchronously. Use start to write the header, write to write a row group, and end to write the footer.

An interface to write a parquet file. Use start to write the header, write to write a row group, and end to write the footer.

Write options of different interfaces on this crate

Enums

The parquet version to use

Functions

Compresses an EncodedPage into a CompressedPage using compressed_buffer as the intermediary buffer.