-
Notifications
You must be signed in to change notification settings - Fork 179
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[CHORE]: Move image kernel out of daft-core (#2804)
- Loading branch information
1 parent
2a89d0d
commit 3e2d25b
Showing
40 changed files
with
1,577 additions
and
1,356 deletions.
There are no files selected for viewing
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,6 @@ | ||
| from daft.daft import ImageFormat, ImageMode, PySeries | ||
|
|
||
| def decode(s: PySeries, raise_error_on_failure: bool, mode: ImageMode | None = None) -> PySeries: ... | ||
| def encode(s: PySeries, image_format: ImageFormat) -> PySeries: ... | ||
| def resize(s: PySeries, w: int, h: int) -> PySeries: ... | ||
| def to_mode(s: PySeries, mode: ImageMode) -> PySeries: ... |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,166 @@ | ||
| use std::vec; | ||
|
|
||
| use common_error::DaftResult; | ||
|
|
||
| use crate::array::prelude::*; | ||
| use crate::datatypes::prelude::*; | ||
|
|
||
| use crate::series::{IntoSeries, Series}; | ||
|
|
||
| #[derive(Clone)] | ||
| pub struct BBox(pub u32, pub u32, pub u32, pub u32); | ||
|
|
||
| impl BBox { | ||
| pub fn from_u32_arrow_array(arr: &dyn arrow2::array::Array) -> Self { | ||
| assert!(arr.len() == 4); | ||
| let mut iter = arr | ||
| .as_any() | ||
| .downcast_ref::<arrow2::array::UInt32Array>() | ||
| .unwrap() | ||
| .iter(); | ||
| BBox( | ||
| *iter.next().unwrap().unwrap(), | ||
| *iter.next().unwrap().unwrap(), | ||
| *iter.next().unwrap().unwrap(), | ||
| *iter.next().unwrap().unwrap(), | ||
| ) | ||
| } | ||
| } | ||
|
|
||
| pub struct ImageArraySidecarData { | ||
| pub channels: Vec<u16>, | ||
| pub heights: Vec<u32>, | ||
| pub widths: Vec<u32>, | ||
| pub modes: Vec<u8>, | ||
| pub validity: Option<arrow2::bitmap::Bitmap>, | ||
| } | ||
|
|
||
| impl ImageArray { | ||
| pub const IMAGE_DATA_IDX: usize = 0; | ||
| pub const IMAGE_CHANNEL_IDX: usize = 1; | ||
| pub const IMAGE_HEIGHT_IDX: usize = 2; | ||
| pub const IMAGE_WIDTH_IDX: usize = 3; | ||
| pub const IMAGE_MODE_IDX: usize = 4; | ||
|
|
||
| pub fn image_mode(&self) -> &Option<ImageMode> { | ||
| match self.data_type() { | ||
| DataType::Image(mode) => mode, | ||
| _ => panic!("Expected dtype to be Image"), | ||
| } | ||
| } | ||
|
|
||
| pub fn data_array(&self) -> &ListArray { | ||
| let array = self.physical.children.get(Self::IMAGE_DATA_IDX).unwrap(); | ||
| array.list().unwrap() | ||
| } | ||
|
|
||
| pub fn channel_array(&self) -> &arrow2::array::UInt16Array { | ||
| let array = self.physical.children.get(Self::IMAGE_CHANNEL_IDX).unwrap(); | ||
| array.u16().unwrap().as_arrow() | ||
| } | ||
|
|
||
| pub fn height_array(&self) -> &arrow2::array::UInt32Array { | ||
| let array = self.physical.children.get(Self::IMAGE_HEIGHT_IDX).unwrap(); | ||
| array.u32().unwrap().as_arrow() | ||
| } | ||
|
|
||
| pub fn width_array(&self) -> &arrow2::array::UInt32Array { | ||
| let array = self.physical.children.get(Self::IMAGE_WIDTH_IDX).unwrap(); | ||
| array.u32().unwrap().as_arrow() | ||
| } | ||
|
|
||
| pub fn mode_array(&self) -> &arrow2::array::UInt8Array { | ||
| let array = self.physical.children.get(Self::IMAGE_MODE_IDX).unwrap(); | ||
| array.u8().unwrap().as_arrow() | ||
| } | ||
|
|
||
| pub fn from_list_array( | ||
| name: &str, | ||
| data_type: DataType, | ||
| data_array: ListArray, | ||
| sidecar_data: ImageArraySidecarData, | ||
| ) -> DaftResult<Self> { | ||
| let values: Vec<Series> = vec![ | ||
| data_array.into_series().rename("data"), | ||
| UInt16Array::from(( | ||
| "channel", | ||
| Box::new( | ||
| arrow2::array::UInt16Array::from_vec(sidecar_data.channels) | ||
| .with_validity(sidecar_data.validity.clone()), | ||
| ), | ||
| )) | ||
| .into_series(), | ||
| UInt32Array::from(( | ||
| "height", | ||
| Box::new( | ||
| arrow2::array::UInt32Array::from_vec(sidecar_data.heights) | ||
| .with_validity(sidecar_data.validity.clone()), | ||
| ), | ||
| )) | ||
| .into_series(), | ||
| UInt32Array::from(( | ||
| "width", | ||
| Box::new( | ||
| arrow2::array::UInt32Array::from_vec(sidecar_data.widths) | ||
| .with_validity(sidecar_data.validity.clone()), | ||
| ), | ||
| )) | ||
| .into_series(), | ||
| UInt8Array::from(( | ||
| "mode", | ||
| Box::new( | ||
| arrow2::array::UInt8Array::from_vec(sidecar_data.modes) | ||
| .with_validity(sidecar_data.validity.clone()), | ||
| ), | ||
| )) | ||
| .into_series(), | ||
| ]; | ||
| let physical_type = data_type.to_physical(); | ||
| let struct_array = StructArray::new( | ||
| Field::new(name, physical_type), | ||
| values, | ||
| sidecar_data.validity, | ||
| ); | ||
| Ok(ImageArray::new(Field::new(name, data_type), struct_array)) | ||
| } | ||
|
|
||
| pub fn from_vecs<T: arrow2::types::NativeType>( | ||
| name: &str, | ||
| data_type: DataType, | ||
| data: Vec<T>, | ||
| offsets: Vec<i64>, | ||
| sidecar_data: ImageArraySidecarData, | ||
| ) -> DaftResult<Self> { | ||
| if data.is_empty() { | ||
| return Ok(ImageArray::full_null(name, &data_type, offsets.len() - 1)); | ||
| } | ||
| let offsets = arrow2::offset::OffsetsBuffer::try_from(offsets)?; | ||
| let arrow_dtype: arrow2::datatypes::DataType = T::PRIMITIVE.into(); | ||
| if let DataType::Image(Some(mode)) = &data_type { | ||
| if mode.get_dtype().to_arrow()? != arrow_dtype { | ||
| panic!("Inner value dtype of provided dtype {data_type:?} is inconsistent with inferred value dtype {arrow_dtype:?}"); | ||
| } | ||
| } | ||
| let data_array = ListArray::new( | ||
| Field::new("data", DataType::List(Box::new((&arrow_dtype).into()))), | ||
| Series::try_from(( | ||
| "data", | ||
| Box::new(arrow2::array::PrimitiveArray::from_vec(data)) | ||
| as Box<dyn arrow2::array::Array>, | ||
| ))?, | ||
| offsets, | ||
| sidecar_data.validity.clone(), | ||
| ); | ||
|
|
||
| Self::from_list_array(name, data_type, data_array, sidecar_data) | ||
| } | ||
| } | ||
|
|
||
| impl FixedShapeImageArray { | ||
| pub fn image_mode(&self) -> &ImageMode { | ||
| match self.data_type() { | ||
| DataType::FixedShapeImage(mode, _, _) => mode, | ||
| other => panic!("Expected dtype to be Image, got {other:?}"), | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.