16935267080

Committed 13 Aug 2025 11:00AM UTC coverage: 24.312% (-63.3%) from 87.658%

Build # 16935267080

Build Type

Pull #4226

github

Committed by

web-flow

Commit Message

Merge 81b48c7fb into baa6ea202

Pull Request Pull Request #4226: Support converting TimestampTZ to and from duckdb

Run Details

0 of 2 new or added lines in 1 file covered. (0.0%)

20666 existing lines in 469 files now uncovered.

8726 of 35892 relevant lines covered (24.31%)

147.74 hits per line

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

31.25

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

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

use std::future::Future;

use futures_util::TryStreamExt;
use vortex_error::VortexResult;

use crate::ArrayRef;
use crate::arrays::ChunkedArray;
use crate::stream::{ArrayStream, SendableArrayStream};

pub trait ArrayStreamExt: ArrayStream {
    /// Box the [`ArrayStream`] so that it can be sent between threads.
    fn boxed(self) -> SendableArrayStream
    where
        Self: Sized + Send + 'static,
    {
        Box::pin(self)
    }

    /// Collect the stream into a single `Array`.
    ///
    /// If the stream yields multiple chunks, they will be returned as a [`ChunkedArray`].
    fn read_all(self) -> impl Future<Output = VortexResult<ArrayRef>>
    where
        Self: Sized,
    {
        async move {
            let dtype = self.dtype().clone();
            let mut chunks: Vec<ArrayRef> = self.try_collect().await?;
            if chunks.len() == 1 {
                Ok(chunks.remove(0))
            } else {
                Ok(ChunkedArray::try_new(chunks, dtype)?.to_array())
            }
        }
    }
}

impl<S: ArrayStream> ArrayStreamExt for S {}

1	// SPDX-License-Identifier: Apache-2.0
2	// SPDX-FileCopyrightText: Copyright the Vortex contributors
3
4	use std::future::Future;
5
6	use futures_util::TryStreamExt;
7	use vortex_error::VortexResult;
8
9	use crate::ArrayRef;
10	use crate::arrays::ChunkedArray;
11	use crate::stream::{ArrayStream, SendableArrayStream};
12
13	pub trait ArrayStreamExt: ArrayStream {
14	/// Box the [`ArrayStream`] so that it can be sent between threads.
15	fn boxed(self) -> SendableArrayStream	6✔
16	where	6✔
17	Self: Sized + Send + 'static,	6✔
18	{
19	Box::pin(self)	6✔
20	}	6✔
21
22	/// Collect the stream into a single `Array`.
23	///
24	/// If the stream yields multiple chunks, they will be returned as a [`ChunkedArray`].
UNCOV 25	fn read_all(self) -> impl Future<Output = VortexResult<ArrayRef>>	×
UNCOV 26	where	×
UNCOV 27	Self: Sized,	×
28	{
UNCOV 29	async move {	×
UNCOV 30	let dtype = self.dtype().clone();	×
UNCOV 31	let mut chunks: Vec<ArrayRef> = self.try_collect().await?;	×
UNCOV 32	if chunks.len() == 1 {	×
UNCOV 33	Ok(chunks.remove(0))	×
34	} else {
35	Ok(ChunkedArray::try_new(chunks, dtype)?.to_array())	×
36	}
UNCOV 37	}	×
UNCOV 38	}	×
39	}
40
41	impl<S: ArrayStream> ArrayStreamExt for S {}

vortex-data / vortex / 16935267080

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