mod merge_parquet¶
- module merge_parquet¶
Parquet output for the merge command.
Writes the merged marker depth table as a Parquet file with ZSTD compression. Schema: id (UInt64), sequence (Utf8), sample_1..sample_N (UInt16, nullable).
Functions
- fn write_parquet(path: &str, sample_names: &[String], rows: impl Iterator<Item = (u64, Vec<u8>, Vec<u16>)>) -> Result<(), Box<dyn std::error::Error>>¶
Write a batch of merged markers to a Parquet file. Called from
merge::runwhen--output-parquetis set.
- fn write_parquet(_path: &str, _sample_names: &[String], _rows: impl Iterator<Item = (u64, Vec<u8>, Vec<u16>)>) -> Result<(), Box<dyn std::error::Error>>¶
Stub for non-parquet builds.