Skip to content

Commit 8d0abda

Browse files
committed
Revert ParquetMetadataReader changes
Deprecation starts only with parquet v56.1.0 and the updated methods don't exist prior to it. Removing this change to leave more room for different parquet/ arrow/ ... versions.
1 parent 3a78a0f commit 8d0abda

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

crates/iceberg/src/arrow/reader.rs

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -39,9 +39,7 @@ use parquet::arrow::arrow_reader::{
3939
};
4040
use parquet::arrow::async_reader::AsyncFileReader;
4141
use parquet::arrow::{PARQUET_FIELD_ID_META_KEY, ParquetRecordBatchStreamBuilder, ProjectionMask};
42-
use parquet::file::metadata::{
43-
PageIndexPolicy, ParquetMetaData, ParquetMetaDataReader, RowGroupMetaData,
44-
};
42+
use parquet::file::metadata::{ParquetMetaData, ParquetMetaDataReader, RowGroupMetaData};
4543
use parquet::schema::types::{SchemaDescriptor, Type as ParquetType};
4644

4745
use crate::arrow::caching_delete_file_loader::CachingDeleteFileLoader;
@@ -1392,9 +1390,9 @@ impl<R: FileRead> AsyncFileReader for ArrowFileReader<R> {
13921390
async move {
13931391
let reader = ParquetMetaDataReader::new()
13941392
.with_prefetch_hint(self.metadata_size_hint)
1395-
.with_column_index_policy(PageIndexPolicy::from(self.preload_column_index))
1396-
.with_page_index_policy(PageIndexPolicy::from(self.preload_page_index))
1397-
.with_offset_index_policy(PageIndexPolicy::from(self.preload_offset_index));
1393+
.with_column_indexes(self.preload_column_index)
1394+
.with_page_indexes(self.preload_page_index)
1395+
.with_offset_indexes(self.preload_offset_index);
13981396
let size = self.meta.size;
13991397
let meta = reader.load_and_finish(self, size).await?;
14001398

0 commit comments

Comments
 (0)