Skip to content

Commit 80a629b

Browse files
committed
feat(parquet): add schema projection for parquet
1 parent 3d617a8 commit 80a629b

File tree

5 files changed

+842
-14
lines changed

5 files changed

+842
-14
lines changed

src/iceberg/parquet/parquet_reader.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,7 @@ class ParquetReader::Impl {
218218
}
219219

220220
// Create the record batch reader
221-
ICEBERG_ASSIGN_OR_RAISE(auto column_indices, SelectedColumnIndices(projection_));
221+
auto column_indices = SelectedColumnIndices(projection_);
222222
ICEBERG_ARROW_ASSIGN_OR_RETURN(
223223
context_->record_batch_reader_,
224224
reader_->GetRecordBatchReader(row_group_indices, column_indices));

0 commit comments

Comments
 (0)