Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
doupache committed Sep 28, 2024
1 parent 6765508 commit 3299f16
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions datafusion/physical-plan/src/repartition/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -299,8 +299,7 @@ impl BatchPartitioner {
let _timer = partitioner_timer.timer();

// Produce batches based on indices
let columns =
take_arrays(batch.columns(), &indices)?;
let columns = take_arrays(batch.columns(), &indices)?;

let mut options = RecordBatchOptions::new();
options = options.with_row_count(Some(indices.len()));
Expand Down

0 comments on commit 3299f16

Please sign in to comment.