16728097825

Committed 04 Aug 2025 04:00PM UTC coverage: 48.355% (-35.1%) from 83.429%

Build # 16728097825

Build Type

Pull #4108

github

Committed by

web-flow

Commit Message

Merge 1b2d27fd8 into 649ba9576

Pull Request Pull Request #4108: perf[vortex-array]: use all_valid instead of `invalid_count() == 0`

Run Details

1 of 1 new or added line in 1 file covered. (100.0%)

11596 existing lines in 378 files now uncovered.

18635 of 38538 relevant lines covered (48.35%)

151786.4 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/vortex-array/src/stream/mod.rs

// SPDX-License-Identifier: Apache-2.0
// SPDX-FileCopyrightText: Copyright the Vortex contributors

use std::pin::Pin;

pub use adapter::*;
pub use ext::*;
use futures_util::{Stream, stream};
use vortex_dtype::DType;
use vortex_error::VortexResult;

use crate::{Array, ArrayRef};

mod adapter;
mod ext;

/// A stream of array chunks along with a DType.
///
/// Can be thought of as equivalent to Arrow's RecordBatchReader.
pub trait ArrayStream: Stream<Item = VortexResult<ArrayRef>> {
    fn dtype(&self) -> &DType;
}

/// Trait for a [`Stream`] of [`ArrayRef`]s that can be passed between threads.
pub type SendableArrayStream = Pin<Box<dyn ArrayStream + Send>>;

impl ArrayStream for SendableArrayStream {
    fn dtype(&self) -> &DType {
        (**self).dtype()
    }
}

impl dyn Array + '_ {
    /// Create an [`ArrayStream`] over the array.
    pub fn to_array_stream(&self) -> impl ArrayStream + 'static {
        ArrayStreamAdapter::new(self.dtype().clone(), stream::iter(self.to_array_iterator()))
    }
}

1	// SPDX-License-Identifier: Apache-2.0
2	// SPDX-FileCopyrightText: Copyright the Vortex contributors
3
4	use std::pin::Pin;
5
6	pub use adapter::*;
7	pub use ext::*;
8	use futures_util::{Stream, stream};
9	use vortex_dtype::DType;
10	use vortex_error::VortexResult;
11
12	use crate::{Array, ArrayRef};
13
14	mod adapter;
15	mod ext;
16
17	/// A stream of array chunks along with a DType.
18	///
19	/// Can be thought of as equivalent to Arrow's RecordBatchReader.
20	pub trait ArrayStream: Stream<Item = VortexResult<ArrayRef>> {
21	fn dtype(&self) -> &DType;
22	}
23
24	/// Trait for a [`Stream`] of [`ArrayRef`]s that can be passed between threads.
25	pub type SendableArrayStream = Pin<Box<dyn ArrayStream + Send>>;
26
27	impl ArrayStream for SendableArrayStream {
28	fn dtype(&self) -> &DType {	×
29	(**self).dtype()	×
30	}	×
31	}
32
33	impl dyn Array + '_ {
34	/// Create an [`ArrayStream`] over the array.
UNCOV 35	pub fn to_array_stream(&self) -> impl ArrayStream + 'static {	×
UNCOV 36	ArrayStreamAdapter::new(self.dtype().clone(), stream::iter(self.to_array_iterator()))	×
UNCOV 37	}	×
38	}

vortex-data / vortex / 16728097825

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous