Skip to content

Commit

Permalink
clippy now fixed
Browse files Browse the repository at this point in the history
  • Loading branch information
angelip2303 committed Mar 11, 2024
1 parent 3fd018d commit 598c204
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/storage/layout/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ pub trait LayoutOps<C> {
let columns = arr.shape()[1] as usize;
let count = AtomicU64::new(0);
let binding = self.graph_iter(graph.to_owned());
let iter = binding.chunks_exact(rows_per_shard(&arr) as usize);
let iter = binding.chunks_exact(rows_per_shard(arr) as usize);
let remainder = iter.remainder();

for chunk in iter {
Expand All @@ -84,15 +84,15 @@ pub trait LayoutOps<C> {
// first we count the number of shards that have been processed, and
// multiply it by the number of chunks in every shard. Hence, we will
// obtain the number of rows that have been processed
let rows_processed = count.load(Ordering::Relaxed) * rows_per_shard(&arr);
let rows_processed = count.load(Ordering::Relaxed) * rows_per_shard(arr);
// then we obtain the size of the last shard that is going to be
// processed; it is equals to the size of the remainder
let last_shard_size = remainder.len() as u64;
// lastly, we store the elements in the provided subset
arr.store_array_subset_elements::<u32>(
&ArraySubset::new_with_start_shape(
vec![rows_processed, 0],
vec![last_shard_size, columns_per_shard(&arr)],
vec![last_shard_size, columns_per_shard(arr)],
)?,
self.store_chunk_elements(remainder, columns),
)?;
Expand Down

0 comments on commit 598c204

Please sign in to comment.