We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 38035c9 commit eec4c58Copy full SHA for eec4c58
kernel/examples/read-table-multi-threaded/src/main.rs
@@ -175,7 +175,7 @@ fn try_main() -> DeltaResult<()> {
175
let (mut scan_file_tx, scan_file_rx) = spmc::channel();
176
177
// fire up each thread. they will be automatically joined at the end due to the scope
178
- thread::scope(|s| -> DeltaResult<()> {
+ thread::scope(|s| {
179
(0..cli.thread_count).for_each(|_| {
180
// items that we need to send to the other thread
181
let scan_state = Arc::new(ScanState {
@@ -223,7 +223,6 @@ fn try_main() -> DeltaResult<()> {
223
// simply gather up all batches
224
record_batch_rx.iter().collect()
225
};
226
-
227
print_batches(&batches)?;
228
Ok(())
229
})
0 commit comments