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 7fe19a2 commit 6ce98adCopy full SHA for 6ce98ad
datafusion/core/src/datasource/physical_plan/arrow_file.rs
@@ -309,10 +309,8 @@ impl FileOpener for ArrowOpener {
309
for (dict_block, dict_result) in
310
footer.dictionaries().iter().flatten().zip(dict_results)
311
{
312
- decoder.read_dictionary(
313
- dict_block,
314
- &Buffer::from(dict_result),
315
- )?;
+ decoder
+ .read_dictionary(dict_block, &Buffer::from(dict_result))?;
316
}
317
318
// filter recordbatches according to range
@@ -348,10 +346,7 @@ impl FileOpener for ArrowOpener {
348
346
.zip(recordbatch_results)
349
347
.filter_map(move |(block, data)| {
350
decoder
351
- .read_record_batch(
352
- &block,
353
- &Buffer::from(data),
354
- )
+ .read_record_batch(&block, &Buffer::from(data))
355
.transpose()
356
}),
357
)
0 commit comments