Skip to content

Commit 7b3bf0f

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 588d5a2 commit 7b3bf0f

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)