Skip to content
This repository has been archived by the owner on Feb 18, 2024. It is now read-only.

Commit

Permalink
Made ZSTD consumable by pyarrow (#675)
Browse files Browse the repository at this point in the history
  • Loading branch information
jorgecarleitao authored Dec 12, 2021
1 parent 915cb6c commit 89921d3
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/io/ipc/compression.rs
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ pub fn compress_lz4(input_buf: &[u8], output_buf: &mut Vec<u8>) -> Result<()> {
#[cfg_attr(docsrs, doc(cfg(feature = "io_ipc_compression")))]
pub fn compress_zstd(input_buf: &[u8], output_buf: &mut Vec<u8>) -> Result<()> {
use std::io::Write;
let mut encoder = zstd::Encoder::new(output_buf, 17)?.auto_finish();
let mut encoder = zstd::Encoder::new(output_buf, 0)?.auto_finish();
encoder.write_all(input_buf).map_err(|e| e.into())
}

Expand Down

0 comments on commit 89921d3

Please sign in to comment.