aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-02-05 00:04:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

simplify vector_slice operation

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-10-09 17:11:13 +04:00
parent d7f3a450ad
commit 9e68fa7f4a
1 changed files with 18 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
core/vector/operations/slice.rs
View File

@@ -3,51 +3,25 @@ use crate::{
LimboError, Result,
};
pub fn vector_slice(vector: &Vector, start_idx: usize, end_idx: usize) -> Result<Vector> {
fn extract_bytes<T, const N: usize>(
slice: &[T],
start: usize,
end: usize,
to_bytes: impl Fn(&T) -> [u8; N],
) -> Result<Vec<u8>> {
if start > end {
return Err(LimboError::InvalidArgument(
"start index must not be greater than end index".into(),
));
}
if end > slice.len() || end < start {
return Err(LimboError::ConversionError(
"vector_slice range out of bounds".into(),
));
}
let mut buf = Vec::with_capacity((end - start) * N);
for item in &slice[start..end] {
buf.extend_from_slice(&to_bytes(item));
}
Ok(buf)
pub fn vector_slice(vector: &Vector, start: usize, end: usize) -> Result<Vector> {
if start > end {
return Err(LimboError::InvalidArgument(
"start index must not be greater than end index".into(),
));
}
if end > vector.dims || end < start {
return Err(LimboError::ConversionError(
"vector_slice range out of bounds".into(),
));
}
match vector.vector_type {
VectorType::Float32Dense => {
Vector::from_data(vector.vector_type, vector.data[start * 4..end * 4].to_vec())
}
VectorType::Float64Dense => {
Vector::from_data(vector.vector_type, vector.data[start * 8..end * 8].to_vec())
}
}
let (vector_type, data) = match vector.vector_type {
VectorType::Float32Dense => (
VectorType::Float32Dense,
extract_bytes::<f32, 4>(vector.as_f32_slice(), start_idx, end_idx, |v| {
v.to_le_bytes()
})?,
),
VectorType::Float64Dense => (
VectorType::Float64Dense,
extract_bytes::<f64, 8>(vector.as_f64_slice(), start_idx, end_idx, |v| {
v.to_le_bytes()
})?,
),
};
Ok(Vector {
vector_type,
dims: end_idx - start_idx,
data,
})
}
#[cfg(test)]