fix(datafusion): resolve conflicts

toutane · toutane · commit 70bc487bcbd7 · 2026-04-29T16:47:46.000+02:00
diff --git a/crates/iceberg/src/scan/mod.rs b/crates/iceberg/src/scan/mod.rs
@@ -457,7 +457,7 @@ impl TableScan {
             arrow_reader_builder = arrow_reader_builder.with_batch_size(batch_size);
         }
 
-        arrow_reader_builder.build().read(tasks)
+        arrow_reader_builder.build().read(tasks).map(|r| r.stream())
     }
 
     /// Returns a reference to the column names of the table scan.

Original file line number	Diff line number	Diff line change
`@@ -457,7 +457,7 @@ impl TableScan {`
`457`	`457`	`arrow_reader_builder = arrow_reader_builder.with_batch_size(batch_size);`
`458`	`458`	`}`
`459`	`459`
`460`		`- arrow_reader_builder.build().read(tasks)`
	`460`	`+ arrow_reader_builder.build().read(tasks).map(\|r\| r.stream())`
`461`	`461`	`}`
`462`	`462`
`463`	`463`	`/// Returns a reference to the column names of the table scan.`