This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new a64f36d8fb MINOR: change file to column index in page_filter trace log
(#7730)
a64f36d8fb is described below
commit a64f36d8fbce35cb7146271fb5d9ab98a9f094e6
Author: mwish <[email protected]>
AuthorDate: Wed Oct 4 04:46:51 2023 +0800
MINOR: change file to column index in page_filter trace log (#7730)
* MINOR: change file to column index in page_filter trace log
* apply suggestion from review: add comma
---
.../datasource/physical_plan/parquet/page_filter.rs | 20 +++++++++++---------
1 file changed, 11 insertions(+), 9 deletions(-)
diff --git
a/datafusion/core/src/datasource/physical_plan/parquet/page_filter.rs
b/datafusion/core/src/datasource/physical_plan/parquet/page_filter.rs
index e5c1d8feb0..b5b5f154f7 100644
--- a/datafusion/core/src/datasource/physical_plan/parquet/page_filter.rs
+++ b/datafusion/core/src/datasource/physical_plan/parquet/page_filter.rs
@@ -147,17 +147,19 @@ impl PagePruningPredicate {
let file_offset_indexes = file_metadata.offset_index();
let file_page_indexes = file_metadata.column_index();
- let (file_offset_indexes, file_page_indexes) =
- match (file_offset_indexes, file_page_indexes) {
- (Some(o), Some(i)) => (o, i),
- _ => {
- trace!(
- "skip page pruning due to lack of indexes. Have offset: {}
file: {}",
+ let (file_offset_indexes, file_page_indexes) = match (
+ file_offset_indexes,
+ file_page_indexes,
+ ) {
+ (Some(o), Some(i)) => (o, i),
+ _ => {
+ trace!(
+ "skip page pruning due to lack of indexes. Have offset:
{}, column index: {}",
file_offset_indexes.is_some(), file_page_indexes.is_some()
);
- return Ok(None);
- }
- };
+ return Ok(None);
+ }
+ };
let mut row_selections =
Vec::with_capacity(page_index_predicates.len());
for predicate in page_index_predicates {
