Skip to content

Commit 3257531

Browse files
committed
deser array tree from a vortex array
Signed-off-by: Onur Satici <onur@spiraldb.com>
1 parent 906945c commit 3257531

3 files changed

Lines changed: 1322 additions & 0 deletions

File tree

vortex-array/public-api.lock

Lines changed: 186 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19938,6 +19938,100 @@ pub fn S::search_sorted_by<F, N>(&self, F, N, vortex_array::search_sorted::Searc
1993819938

1993919939
pub mod vortex_array::serde
1994019940

19941+
pub mod vortex_array::serde::columnar
19942+
19943+
pub struct vortex_array::serde::columnar::ColumnarArrayTree
19944+
19945+
pub vortex_array::serde::columnar::ColumnarArrayTree::buffers: vortex_array::arrays::StructArray
19946+
19947+
pub vortex_array::serde::columnar::ColumnarArrayTree::nodes: vortex_array::arrays::StructArray
19948+
19949+
impl vortex_array::serde::columnar::ColumnarArrayTree
19950+
19951+
pub fn vortex_array::serde::columnar::ColumnarArrayTree::nnodes(&self) -> usize
19952+
19953+
pub fn vortex_array::serde::columnar::ColumnarArrayTree::try_new(vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::VarBinViewArray, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray, vortex_array::serde::columnar::StatsColumns, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray) -> vortex_error::VortexResult<Self>
19954+
19955+
impl core::clone::Clone for vortex_array::serde::columnar::ColumnarArrayTree
19956+
19957+
pub fn vortex_array::serde::columnar::ColumnarArrayTree::clone(&self) -> vortex_array::serde::columnar::ColumnarArrayTree
19958+
19959+
impl core::fmt::Debug for vortex_array::serde::columnar::ColumnarArrayTree
19960+
19961+
pub fn vortex_array::serde::columnar::ColumnarArrayTree::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
19962+
19963+
pub struct vortex_array::serde::columnar::ColumnarSerializedArray
19964+
19965+
impl vortex_array::serde::columnar::ColumnarSerializedArray
19966+
19967+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::child(&self, usize) -> vortex_array::serde::columnar::ColumnarSerializedArray
19968+
19969+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::decode(&self, &vortex_array::dtype::DType, usize, &vortex_session::registry::ReadContext, &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_array::ArrayRef>
19970+
19971+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::encoding_id(&self) -> u16
19972+
19973+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::from_segment_and_tree(vortex_array::buffer::BufferHandle, alloc::sync::Arc<vortex_array::serde::columnar::ColumnarArrayTree>) -> vortex_error::VortexResult<Self>
19974+
19975+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::metadata(&self) -> vortex_buffer::ByteBuffer
19976+
19977+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::nbuffers(&self) -> usize
19978+
19979+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::nchildren(&self) -> usize
19980+
19981+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::new(alloc::sync::Arc<vortex_array::serde::columnar::ColumnarArrayTree>, alloc::sync::Arc<[vortex_array::buffer::BufferHandle]>) -> vortex_error::VortexResult<Self>
19982+
19983+
impl core::clone::Clone for vortex_array::serde::columnar::ColumnarSerializedArray
19984+
19985+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::clone(&self) -> vortex_array::serde::columnar::ColumnarSerializedArray
19986+
19987+
impl core::fmt::Debug for vortex_array::serde::columnar::ColumnarSerializedArray
19988+
19989+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
19990+
19991+
pub struct vortex_array::serde::columnar::StatsColumns(_)
19992+
19993+
impl vortex_array::serde::columnar::StatsColumns
19994+
19995+
pub fn vortex_array::serde::columnar::StatsColumns::as_struct(&self) -> &vortex_array::arrays::StructArray
19996+
19997+
pub fn vortex_array::serde::columnar::StatsColumns::into_struct(self) -> vortex_array::arrays::StructArray
19998+
19999+
pub fn vortex_array::serde::columnar::StatsColumns::new(vortex_array::arrays::StructArray) -> vortex_error::VortexResult<Self>
20000+
20001+
pub fn vortex_array::serde::columnar::StatsColumns::nrows(&self) -> usize
20002+
20003+
pub fn vortex_array::serde::columnar::StatsColumns::read(&self, usize, &vortex_array::dtype::DType, &mut vortex_array::ExecutionCtx, &vortex_session::VortexSession) -> vortex_error::VortexResult<core::option::Option<vortex_array::stats::StatsSet>>
20004+
20005+
impl core::clone::Clone for vortex_array::serde::columnar::StatsColumns
20006+
20007+
pub fn vortex_array::serde::columnar::StatsColumns::clone(&self) -> vortex_array::serde::columnar::StatsColumns
20008+
20009+
impl core::fmt::Debug for vortex_array::serde::columnar::StatsColumns
20010+
20011+
pub fn vortex_array::serde::columnar::StatsColumns::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
20012+
20013+
pub struct vortex_array::serde::columnar::StatsColumnsBuilder
20014+
20015+
impl vortex_array::serde::columnar::StatsColumnsBuilder
20016+
20017+
pub fn vortex_array::serde::columnar::StatsColumnsBuilder::finish(self) -> vortex_error::VortexResult<vortex_array::serde::columnar::StatsColumns>
20018+
20019+
pub fn vortex_array::serde::columnar::StatsColumnsBuilder::push(&mut self, core::option::Option<&vortex_array::stats::StatsSet>)
20020+
20021+
pub fn vortex_array::serde::columnar::StatsColumnsBuilder::with_capacity(usize) -> Self
20022+
20023+
pub static vortex_array::serde::columnar::BUFFER_COLUMNS_DTYPE: std::sync::lazy_lock::LazyLock<vortex_array::dtype::DType>
20024+
20025+
pub static vortex_array::serde::columnar::NODES_COLUMNS_DTYPE: std::sync::lazy_lock::LazyLock<vortex_array::dtype::DType>
20026+
20027+
pub static vortex_array::serde::columnar::STATS_COLUMNS_DTYPE: std::sync::lazy_lock::LazyLock<vortex_array::dtype::DType>
20028+
20029+
pub fn vortex_array::serde::columnar::compute_buffer_offsets(&[u16]) -> vortex_buffer::buffer::Buffer<u32>
20030+
20031+
pub fn vortex_array::serde::columnar::compute_subtree_sizes(&[u8]) -> vortex_buffer::buffer::Buffer<u32>
20032+
20033+
pub fn vortex_array::serde::columnar::serialize_to_columnar_tree(&vortex_array::ArrayRef, &vortex_array::ArrayContext, &vortex_session::VortexSession, &vortex_array::serde::SerializeOptions) -> vortex_error::VortexResult<(alloc::vec::Vec<vortex_buffer::ByteBuffer>, vortex_array::serde::columnar::ColumnarArrayTree)>
20034+
1994120035
pub struct vortex_array::serde::ArrayNodeFlatBuffer<'a>
1994220036

1994320037
impl<'a> vortex_array::serde::ArrayNodeFlatBuffer<'a>
@@ -19946,6 +20040,54 @@ pub fn vortex_array::serde::ArrayNodeFlatBuffer<'a>::try_new(&'a vortex_array::A
1994620040

1994720041
pub fn vortex_array::serde::ArrayNodeFlatBuffer<'a>::try_write_flatbuffer<'fb>(&self, &mut flatbuffers::builder::FlatBufferBuilder<'fb>) -> vortex_error::VortexResult<flatbuffers::primitives::WIPOffset<vortex_flatbuffers::array::ArrayNode<'fb>>>
1994820042

20043+
pub struct vortex_array::serde::ColumnarArrayTree
20044+
20045+
pub vortex_array::serde::ColumnarArrayTree::buffers: vortex_array::arrays::StructArray
20046+
20047+
pub vortex_array::serde::ColumnarArrayTree::nodes: vortex_array::arrays::StructArray
20048+
20049+
impl vortex_array::serde::columnar::ColumnarArrayTree
20050+
20051+
pub fn vortex_array::serde::columnar::ColumnarArrayTree::nnodes(&self) -> usize
20052+
20053+
pub fn vortex_array::serde::columnar::ColumnarArrayTree::try_new(vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::VarBinViewArray, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray, vortex_array::serde::columnar::StatsColumns, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray, vortex_array::arrays::PrimitiveArray) -> vortex_error::VortexResult<Self>
20054+
20055+
impl core::clone::Clone for vortex_array::serde::columnar::ColumnarArrayTree
20056+
20057+
pub fn vortex_array::serde::columnar::ColumnarArrayTree::clone(&self) -> vortex_array::serde::columnar::ColumnarArrayTree
20058+
20059+
impl core::fmt::Debug for vortex_array::serde::columnar::ColumnarArrayTree
20060+
20061+
pub fn vortex_array::serde::columnar::ColumnarArrayTree::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
20062+
20063+
pub struct vortex_array::serde::ColumnarSerializedArray
20064+
20065+
impl vortex_array::serde::columnar::ColumnarSerializedArray
20066+
20067+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::child(&self, usize) -> vortex_array::serde::columnar::ColumnarSerializedArray
20068+
20069+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::decode(&self, &vortex_array::dtype::DType, usize, &vortex_session::registry::ReadContext, &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_array::ArrayRef>
20070+
20071+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::encoding_id(&self) -> u16
20072+
20073+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::from_segment_and_tree(vortex_array::buffer::BufferHandle, alloc::sync::Arc<vortex_array::serde::columnar::ColumnarArrayTree>) -> vortex_error::VortexResult<Self>
20074+
20075+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::metadata(&self) -> vortex_buffer::ByteBuffer
20076+
20077+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::nbuffers(&self) -> usize
20078+
20079+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::nchildren(&self) -> usize
20080+
20081+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::new(alloc::sync::Arc<vortex_array::serde::columnar::ColumnarArrayTree>, alloc::sync::Arc<[vortex_array::buffer::BufferHandle]>) -> vortex_error::VortexResult<Self>
20082+
20083+
impl core::clone::Clone for vortex_array::serde::columnar::ColumnarSerializedArray
20084+
20085+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::clone(&self) -> vortex_array::serde::columnar::ColumnarSerializedArray
20086+
20087+
impl core::fmt::Debug for vortex_array::serde::columnar::ColumnarSerializedArray
20088+
20089+
pub fn vortex_array::serde::columnar::ColumnarSerializedArray::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
20090+
1994920091
pub struct vortex_array::serde::SerializeOptions
1995020092

1995120093
pub vortex_array::serde::SerializeOptions::include_padding: bool
@@ -20008,6 +20150,44 @@ impl core::fmt::Debug for vortex_array::serde::SerializedArray
2000820150

2000920151
pub fn vortex_array::serde::SerializedArray::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
2001020152

20153+
pub struct vortex_array::serde::StatsColumns(_)
20154+
20155+
impl vortex_array::serde::columnar::StatsColumns
20156+
20157+
pub fn vortex_array::serde::columnar::StatsColumns::as_struct(&self) -> &vortex_array::arrays::StructArray
20158+
20159+
pub fn vortex_array::serde::columnar::StatsColumns::into_struct(self) -> vortex_array::arrays::StructArray
20160+
20161+
pub fn vortex_array::serde::columnar::StatsColumns::new(vortex_array::arrays::StructArray) -> vortex_error::VortexResult<Self>
20162+
20163+
pub fn vortex_array::serde::columnar::StatsColumns::nrows(&self) -> usize
20164+
20165+
pub fn vortex_array::serde::columnar::StatsColumns::read(&self, usize, &vortex_array::dtype::DType, &mut vortex_array::ExecutionCtx, &vortex_session::VortexSession) -> vortex_error::VortexResult<core::option::Option<vortex_array::stats::StatsSet>>
20166+
20167+
impl core::clone::Clone for vortex_array::serde::columnar::StatsColumns
20168+
20169+
pub fn vortex_array::serde::columnar::StatsColumns::clone(&self) -> vortex_array::serde::columnar::StatsColumns
20170+
20171+
impl core::fmt::Debug for vortex_array::serde::columnar::StatsColumns
20172+
20173+
pub fn vortex_array::serde::columnar::StatsColumns::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
20174+
20175+
pub struct vortex_array::serde::StatsColumnsBuilder
20176+
20177+
impl vortex_array::serde::columnar::StatsColumnsBuilder
20178+
20179+
pub fn vortex_array::serde::columnar::StatsColumnsBuilder::finish(self) -> vortex_error::VortexResult<vortex_array::serde::columnar::StatsColumns>
20180+
20181+
pub fn vortex_array::serde::columnar::StatsColumnsBuilder::push(&mut self, core::option::Option<&vortex_array::stats::StatsSet>)
20182+
20183+
pub fn vortex_array::serde::columnar::StatsColumnsBuilder::with_capacity(usize) -> Self
20184+
20185+
pub static vortex_array::serde::BUFFER_COLUMNS_DTYPE: std::sync::lazy_lock::LazyLock<vortex_array::dtype::DType>
20186+
20187+
pub static vortex_array::serde::NODES_COLUMNS_DTYPE: std::sync::lazy_lock::LazyLock<vortex_array::dtype::DType>
20188+
20189+
pub static vortex_array::serde::STATS_COLUMNS_DTYPE: std::sync::lazy_lock::LazyLock<vortex_array::dtype::DType>
20190+
2001120191
pub trait vortex_array::serde::ArrayChildren
2001220192

2001320193
pub fn vortex_array::serde::ArrayChildren::get(&self, usize, &vortex_array::dtype::DType, usize) -> vortex_error::VortexResult<vortex_array::ArrayRef>
@@ -20024,6 +20204,12 @@ pub fn T::is_empty(&self) -> bool
2002420204

2002520205
pub fn T::len(&self) -> usize
2002620206

20207+
pub fn vortex_array::serde::compute_buffer_offsets(&[u16]) -> vortex_buffer::buffer::Buffer<u32>
20208+
20209+
pub fn vortex_array::serde::compute_subtree_sizes(&[u8]) -> vortex_buffer::buffer::Buffer<u32>
20210+
20211+
pub fn vortex_array::serde::serialize_to_columnar_tree(&vortex_array::ArrayRef, &vortex_array::ArrayContext, &vortex_session::VortexSession, &vortex_array::serde::SerializeOptions) -> vortex_error::VortexResult<(alloc::vec::Vec<vortex_buffer::ByteBuffer>, vortex_array::serde::columnar::ColumnarArrayTree)>
20212+
2002720213
pub mod vortex_array::session
2002820214

2002920215
pub struct vortex_array::session::ArraySession

0 commit comments

Comments
 (0)