Skip to content

Commit 6ce98ad

Browse files
committed
fmt
1 parent 7fe19a2 commit 6ce98ad

File tree

1 file changed

+3
-8
lines changed

1 file changed

+3
-8
lines changed

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

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -309,10 +309,8 @@ impl FileOpener for ArrowOpener {
309309
for (dict_block, dict_result) in
310310
footer.dictionaries().iter().flatten().zip(dict_results)
311311
{
312-
decoder.read_dictionary(
313-
dict_block,
314-
&Buffer::from(dict_result),
315-
)?;
312+
decoder
313+
.read_dictionary(dict_block, &Buffer::from(dict_result))?;
316314
}
317315

318316
// filter recordbatches according to range
@@ -348,10 +346,7 @@ impl FileOpener for ArrowOpener {
348346
.zip(recordbatch_results)
349347
.filter_map(move |(block, data)| {
350348
decoder
351-
.read_record_batch(
352-
&block,
353-
&Buffer::from(data),
354-
)
349+
.read_record_batch(&block, &Buffer::from(data))
355350
.transpose()
356351
}),
357352
)

0 commit comments

Comments
 (0)