Module mz_persist_types::parquet

source ·
Expand description

Parquet serialization and deserialization for persist data.

TODO: Move this into mz_persist_client::internal once we don’t need validate_roundtrip.


  • Decodes a RecordBatch from the provided reader.
  • Decodes a part with the given schema from our parquet-based serialization format.
  • Encodes a set of Arrays into Parquet.
  • Encodes the given part into our parquet-based serialization format.
  • A helper for writing tests that validate that a piece of data roundtrips through the parquet serialization format.