Skip to content

Commit

Permalink
Update
Browse files Browse the repository at this point in the history
  • Loading branch information
viirya committed Dec 19, 2022
1 parent 5858949 commit 0fd9095
Showing 1 changed file with 9 additions and 1 deletion.
10 changes: 9 additions & 1 deletion parquet/src/file/writer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
use crate::bloom_filter::Sbbf;
use crate::format as parquet;
use crate::format::{ColumnIndex, OffsetIndex, RowGroup};
use std::io::BufWriter;
use std::io::{BufWriter, IoSlice};
use std::{io::Write, sync::Arc};
use thrift::protocol::{TCompactOutputProtocol, TOutputProtocol, TSerializable};

Expand Down Expand Up @@ -84,6 +84,14 @@ impl<W: Write> Write for TrackedWrite<W> {
Ok(bytes)
}

fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> std::io::Result<usize> {
self.inner.write_vectored(bufs)
}

fn write_all(&mut self, buf: &[u8]) -> std::io::Result<()> {
self.inner.write_all(buf)
}

fn flush(&mut self) -> std::io::Result<()> {
self.inner.flush()
}
Expand Down

0 comments on commit 0fd9095

Please sign in to comment.