refactor: address Jake's comment

2021-04-16 17:27:40 -04:00 · 2021-04-16 17:27:40 -04:00 · b3e110a241
parent 41aa4d5475
commit b3e110a241
1 changed files with 2 additions and 2 deletions
--- a/parquet_file/src/storage.rs
+++ b/parquet_file/src/storage.rs
@ -301,7 +301,7 @@ impl Storage {
            if let Err(e) = Self::read_file(
                filename,
                projection.as_slice(),
-                &predicate_builder,
+                predicate_builder.as_ref(),
                batch_size,
                response_tx,
                limit,
@ -331,7 +331,7 @@ impl Storage {
    fn read_file(
        filename: String,
        projection: &[usize],
-        predicate_builder: &Option<RowGroupPredicateBuilder>,
+        predicate_builder: Option<&RowGroupPredicateBuilder>,
        batch_size: usize,
        response_tx: Sender<ArrowResult<RecordBatch>>,
        limit: Option<usize>,