Skip to content

Commit

Permalink
nit
Browse files Browse the repository at this point in the history
  • Loading branch information
jdcasale committed Apr 30, 2024
1 parent 128d5d8 commit cd44275
Showing 1 changed file with 8 additions and 8 deletions.
16 changes: 8 additions & 8 deletions vortex-array/src/array/chunked/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -91,13 +91,13 @@ impl ChunkedArray<'_> {
}

impl<'a> ChunkedArray<'a> {
pub fn chunks(&'a self) -> impl Iterator<Item=Array<'a>> {
pub fn chunks(&'a self) -> impl Iterator<Item = Array<'a>> {
(0..self.nchunks()).map(|c| self.chunk(c).unwrap())
}
}

impl FromIterator<OwnedArray> for OwnedChunkedArray {
fn from_iter<T: IntoIterator<Item=OwnedArray>>(iter: T) -> Self {
fn from_iter<T: IntoIterator<Item = OwnedArray>>(iter: T) -> Self {
let chunks: Vec<OwnedArray> = iter.into_iter().collect();
let dtype = chunks
.first()
Expand All @@ -109,8 +109,8 @@ impl FromIterator<OwnedArray> for OwnedChunkedArray {

impl ArrayFlatten for ChunkedArray<'_> {
fn flatten<'a>(self) -> VortexResult<Flattened<'a>>
where
Self: 'a,
where
Self: 'a,
{
Ok(Flattened::Chunked(self))
}
Expand Down Expand Up @@ -177,7 +177,7 @@ mod test {
Nullability::NonNullable,
),
)
.unwrap()
.unwrap()
}

#[allow(dead_code)]
Expand All @@ -201,9 +201,9 @@ mod test {
vec![chunk1, chunk2],
DType::Float(64.into(), Nullability::NonNullable),
)
.unwrap()
.to_array()
.to_static();
.unwrap()
.to_array()
.to_static();

let array = scalar_subtract(&chunked, to_subtract).unwrap();

Expand Down

0 comments on commit cd44275

Please sign in to comment.