16361873809

Committed 18 Jul 2025 04:02AM UTC coverage: 80.939% (-0.04%) from 80.979%

Build # 16361873809

Build Type

Pull #3792

github

Committed by

web-flow

Commit Message

Merge 14c05cab0 into 73e365cd9

Pull Request Pull Request #3792: Vortex - C++ API

Run Details

9 of 38 new or added lines in 3 files covered. (23.68%)

2 existing lines in 1 file now uncovered.

42000 of 51891 relevant lines covered (80.94%)

170546.17 hits per line

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

50.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};
pub use to_iterator::*;
use vortex_dtype::DType;
use vortex_error::VortexResult;

use crate::{Array, ArrayRef};

mod adapter;
mod ext;
mod to_iterator;

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

vortex-data / vortex / 16361873809

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