Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
YangchenYe323 committed Mar 25, 2024
1 parent cca4542 commit dccc322
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion column-sketch-eval/src/parquet.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,10 @@ use futures::StreamExt;
use parquet::{arrow::ParquetRecordBatchStreamBuilder, file::statistics::Statistics::Double};

/// Return all the records greater than target
pub async fn execute_plain_parquet(path: impl AsRef<Path>, target: f64) -> Result<Vec<RecordBatch>> {
pub async fn execute_plain_parquet(
path: impl AsRef<Path>,
target: f64,
) -> Result<Vec<RecordBatch>> {
let file = tokio::fs::File::open(path).await?;

let stream_builder = ParquetRecordBatchStreamBuilder::new(file).await?;
Expand Down

0 comments on commit dccc322

Please sign in to comment.