We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5902602 commit 2f21a2dCopy full SHA for 2f21a2d
1 file changed
pyiceberg/io/pyarrow.py
@@ -1492,16 +1492,14 @@ def _task_to_record_batches(
1492
1493
current_batch = table.combine_chunks().to_batches()[0]
1494
1495
- result_batch = _to_requested_schema(
+ yield _to_requested_schema(
1496
projected_schema,
1497
file_project_schema,
1498
current_batch,
1499
downcast_ns_timestamp_to_us=True,
1500
projected_missing_fields=projected_missing_fields,
1501
)
1502
1503
- yield result_batch
1504
-
1505
1506
def _read_all_delete_files(io: FileIO, tasks: Iterable[FileScanTask]) -> Dict[str, List[ChunkedArray]]:
1507
deletes_per_file: Dict[str, List[ChunkedArray]] = {}
0 commit comments