Skip to content

Commit 0bbce5d

Browse files
authored
[Minor]: Refactor to use Result.transpose() (#11882)
`Result.transpose()` converts `Result<Option<T>>` to `Option<Result<T>>`. > Ok(None) will be mapped to None. Ok(Some(_)) and Err(_) will be mapped to Some(Ok(_)) and Some(Err(_)). - https://doc.rust-lang.org/std/result/enum.Result.html#method.transpose
1 parent 053795c commit 0bbce5d

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

datafusion/core/src/datasource/physical_plan/arrow_file.rs

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -331,11 +331,9 @@ impl FileOpener for ArrowOpener {
331331
.into_iter()
332332
.zip(recordbatch_results)
333333
.filter_map(move |(block, data)| {
334-
match decoder.read_record_batch(&block, &data.into()) {
335-
Ok(Some(record_batch)) => Some(Ok(record_batch)),
336-
Ok(None) => None,
337-
Err(err) => Some(Err(err)),
338-
}
334+
decoder
335+
.read_record_batch(&block, &data.into())
336+
.transpose()
339337
}),
340338
)
341339
.boxed())

0 commit comments

Comments
 (0)