-
Notifications
You must be signed in to change notification settings - Fork 130
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Adds ZST support in Deduper and Mixer #170
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looks good overall, with minor comments.
// the local_input path, because the local_input path could be a temporary with suffix ".tmp" | ||
let input_compression: String = match compression.input { | ||
Some(ref input) => input.clone(), | ||
None => MultiStream::infer_compression_from_temp(local_input.clone()), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think the comment contradicts what you're doing here - you say you'll use docs_location but use local_input
src/shard.rs
Outdated
); | ||
let mut writer = output_stream.writer()?; | ||
// let output_file = OpenOptions::new() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove commented code ?
src/shard.rs
Outdated
local_attr_readers.push((local_attr_file, attr_reader.lines())); | ||
attr_reader_failure_counts.push(0); | ||
|
||
// let f = OpenOptions::new() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove
No description provided.