pub mod vortex_layout

pub mod vortex_layout::aliases

pub mod vortex_layout::aliases::paste

pub use vortex_layout::aliases::paste::paste

pub mod vortex_layout::display

pub struct vortex_layout::display::DisplayLayoutTree

impl vortex_layout::display::DisplayLayoutTree

pub fn vortex_layout::display::DisplayLayoutTree::new(layout: vortex_layout::LayoutRef, verbose: bool) -> Self

impl core::fmt::Display for vortex_layout::display::DisplayLayoutTree

pub fn vortex_layout::display::DisplayLayoutTree::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

pub mod vortex_layout::layouts

pub mod vortex_layout::layouts::buffered

pub struct vortex_layout::layouts::buffered::BufferedStrategy

impl vortex_layout::layouts::buffered::BufferedStrategy

pub fn vortex_layout::layouts::buffered::BufferedStrategy::new<S: vortex_layout::LayoutStrategy>(child: S, buffer_size: u64) -> Self

impl core::clone::Clone for vortex_layout::layouts::buffered::BufferedStrategy

pub fn vortex_layout::layouts::buffered::BufferedStrategy::clone(&self) -> vortex_layout::layouts::buffered::BufferedStrategy

impl vortex_layout::LayoutStrategy for vortex_layout::layouts::buffered::BufferedStrategy

pub fn vortex_layout::layouts::buffered::BufferedStrategy::buffered_bytes(&self) -> u64

pub fn vortex_layout::layouts::buffered::BufferedStrategy::write_stream<'life0, 'life1, 'async_trait>(&'life0 self, ctx: vortex_array::ArrayContext, segment_sink: vortex_layout::segments::SegmentSinkRef, stream: vortex_layout::sequence::SendableSequentialStream, eof: vortex_layout::sequence::SequencePointer, session: &'life1 vortex_session::VortexSession) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = vortex_error::VortexResult<vortex_layout::LayoutRef>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait

pub mod vortex_layout::layouts::chunked

pub mod vortex_layout::layouts::chunked::writer

pub struct vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy

pub vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy::chunk_strategy: alloc::sync::Arc<dyn vortex_layout::LayoutStrategy>

impl vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy

pub fn vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy::new<S: vortex_layout::LayoutStrategy>(chunk_strategy: S) -> Self

impl core::clone::Clone for vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy

pub fn vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy::clone(&self) -> vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy

impl vortex_layout::LayoutStrategy for vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy

pub fn vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy::buffered_bytes(&self) -> u64

pub fn vortex_layout::layouts::chunked::writer::ChunkedLayoutStrategy::write_stream<'life0, 'life1, 'async_trait>(&'life0 self, ctx: vortex_array::ArrayContext, segment_sink: vortex_layout::segments::SegmentSinkRef, stream: vortex_layout::sequence::SendableSequentialStream, eof: vortex_layout::sequence::SequencePointer, session: &'life1 vortex_session::VortexSession) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = vortex_error::VortexResult<vortex_layout::LayoutRef>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait

pub struct vortex_layout::layouts::chunked::Chunked

impl core::fmt::Debug for vortex_layout::layouts::chunked::Chunked

pub fn vortex_layout::layouts::chunked::Chunked::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl vortex_layout::VTable for vortex_layout::layouts::chunked::Chunked

pub type vortex_layout::layouts::chunked::Chunked::Encoding = vortex_layout::layouts::chunked::ChunkedLayoutEncoding

pub type vortex_layout::layouts::chunked::Chunked::Layout = vortex_layout::layouts::chunked::ChunkedLayout

pub type vortex_layout::layouts::chunked::Chunked::Metadata = vortex_array::metadata::EmptyMetadata

pub fn vortex_layout::layouts::chunked::Chunked::build(_encoding: &Self::Encoding, dtype: &vortex_array::dtype::DType, row_count: u64, _metadata: &<Self::Metadata as vortex_array::metadata::DeserializeMetadata>::Output, _segment_ids: alloc::vec::Vec<vortex_layout::segments::SegmentId>, children: &dyn vortex_layout::LayoutChildren, _ctx: &vortex_session::registry::ReadContext) -> vortex_error::VortexResult<Self::Layout>

pub fn vortex_layout::layouts::chunked::Chunked::child(layout: &Self::Layout, idx: usize) -> vortex_error::VortexResult<vortex_layout::LayoutRef>

pub fn vortex_layout::layouts::chunked::Chunked::child_type(layout: &Self::Layout, idx: usize) -> vortex_layout::LayoutChildType

pub fn vortex_layout::layouts::chunked::Chunked::dtype(layout: &Self::Layout) -> &vortex_array::dtype::DType

pub fn vortex_layout::layouts::chunked::Chunked::encoding(_layout: &Self::Layout) -> vortex_layout::LayoutEncodingRef

pub fn vortex_layout::layouts::chunked::Chunked::id(_encoding: &Self::Encoding) -> vortex_layout::LayoutId

pub fn vortex_layout::layouts::chunked::Chunked::metadata(_layout: &Self::Layout) -> Self::Metadata

pub fn vortex_layout::layouts::chunked::Chunked::nchildren(layout: &Self::Layout) -> usize

pub fn vortex_layout::layouts::chunked::Chunked::new_reader(layout: &Self::Layout, name: alloc::sync::Arc<str>, segment_source: alloc::sync::Arc<dyn vortex_layout::segments::SegmentSource>, session: &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_layout::LayoutReaderRef>

pub fn vortex_layout::layouts::chunked::Chunked::row_count(layout: &Self::Layout) -> u64

pub fn vortex_layout::layouts::chunked::Chunked::segment_ids(_layout: &Self::Layout) -> alloc::vec::Vec<vortex_layout::segments::SegmentId>

pub fn vortex_layout::layouts::chunked::Chunked::with_children(layout: &mut Self::Layout, children: alloc::vec::Vec<vortex_layout::LayoutRef>) -> vortex_error::VortexResult<()>

pub struct vortex_layout::layouts::chunked::ChunkedLayout

impl vortex_layout::layouts::chunked::ChunkedLayout

pub fn vortex_layout::layouts::chunked::ChunkedLayout::children(&self) -> &alloc::sync::Arc<dyn vortex_layout::LayoutChildren>

pub fn vortex_layout::layouts::chunked::ChunkedLayout::new(row_count: u64, dtype: vortex_array::dtype::DType, children: alloc::sync::Arc<dyn vortex_layout::LayoutChildren>) -> Self

impl core::clone::Clone for vortex_layout::layouts::chunked::ChunkedLayout

pub fn vortex_layout::layouts::chunked::ChunkedLayout::clone(&self) -> vortex_layout::layouts::chunked::ChunkedLayout

impl core::convert::AsRef<dyn vortex_layout::Layout> for vortex_layout::layouts::chunked::ChunkedLayout

pub fn vortex_layout::layouts::chunked::ChunkedLayout::as_ref(&self) -> &dyn vortex_layout::Layout

impl core::convert::From<vortex_layout::layouts::chunked::ChunkedLayout> for vortex_layout::LayoutRef

pub fn vortex_layout::LayoutRef::from(value: vortex_layout::layouts::chunked::ChunkedLayout) -> vortex_layout::LayoutRef

impl core::fmt::Debug for vortex_layout::layouts::chunked::ChunkedLayout

pub fn vortex_layout::layouts::chunked::ChunkedLayout::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::chunked::ChunkedLayout

pub type vortex_layout::layouts::chunked::ChunkedLayout::Target = dyn vortex_layout::Layout

pub fn vortex_layout::layouts::chunked::ChunkedLayout::deref(&self) -> &Self::Target

impl vortex_layout::IntoLayout for vortex_layout::layouts::chunked::ChunkedLayout

pub fn vortex_layout::layouts::chunked::ChunkedLayout::into_layout(self) -> vortex_layout::LayoutRef

pub struct vortex_layout::layouts::chunked::ChunkedLayoutEncoding

impl core::convert::AsRef<dyn vortex_layout::LayoutEncoding> for vortex_layout::layouts::chunked::ChunkedLayoutEncoding

pub fn vortex_layout::layouts::chunked::ChunkedLayoutEncoding::as_ref(&self) -> &dyn vortex_layout::LayoutEncoding

impl core::fmt::Debug for vortex_layout::layouts::chunked::ChunkedLayoutEncoding

pub fn vortex_layout::layouts::chunked::ChunkedLayoutEncoding::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::chunked::ChunkedLayoutEncoding

pub type vortex_layout::layouts::chunked::ChunkedLayoutEncoding::Target = dyn vortex_layout::LayoutEncoding

pub fn vortex_layout::layouts::chunked::ChunkedLayoutEncoding::deref(&self) -> &Self::Target

pub mod vortex_layout::layouts::collect

pub struct vortex_layout::layouts::collect::CollectStrategy

impl vortex_layout::layouts::collect::CollectStrategy

pub fn vortex_layout::layouts::collect::CollectStrategy::new<S: vortex_layout::LayoutStrategy>(child: S) -> vortex_layout::layouts::collect::CollectStrategy

impl vortex_layout::LayoutStrategy for vortex_layout::layouts::collect::CollectStrategy

pub fn vortex_layout::layouts::collect::CollectStrategy::buffered_bytes(&self) -> u64

pub fn vortex_layout::layouts::collect::CollectStrategy::write_stream<'life0, 'life1, 'async_trait>(&'life0 self, ctx: vortex_array::ArrayContext, segment_sink: vortex_layout::segments::SegmentSinkRef, stream: vortex_layout::sequence::SendableSequentialStream, eof: vortex_layout::sequence::SequencePointer, session: &'life1 vortex_session::VortexSession) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = vortex_error::VortexResult<vortex_layout::LayoutRef>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait

pub mod vortex_layout::layouts::compressed

pub struct vortex_layout::layouts::compressed::CompressingStrategy

impl vortex_layout::layouts::compressed::CompressingStrategy

pub fn vortex_layout::layouts::compressed::CompressingStrategy::new<S: vortex_layout::LayoutStrategy, C: vortex_layout::layouts::compressed::CompressorPlugin>(child: S, compressor: C) -> Self

pub fn vortex_layout::layouts::compressed::CompressingStrategy::with_concurrency(self, concurrency: usize) -> Self

pub fn vortex_layout::layouts::compressed::CompressingStrategy::with_stats(self, stats: &[vortex_array::expr::stats::Stat]) -> Self

impl core::clone::Clone for vortex_layout::layouts::compressed::CompressingStrategy

pub fn vortex_layout::layouts::compressed::CompressingStrategy::clone(&self) -> vortex_layout::layouts::compressed::CompressingStrategy

impl vortex_layout::LayoutStrategy for vortex_layout::layouts::compressed::CompressingStrategy

pub fn vortex_layout::layouts::compressed::CompressingStrategy::buffered_bytes(&self) -> u64

pub fn vortex_layout::layouts::compressed::CompressingStrategy::write_stream<'life0, 'life1, 'async_trait>(&'life0 self, ctx: vortex_array::ArrayContext, segment_sink: vortex_layout::segments::SegmentSinkRef, stream: vortex_layout::sequence::SendableSequentialStream, eof: vortex_layout::sequence::SequencePointer, session: &'life1 vortex_session::VortexSession) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = vortex_error::VortexResult<vortex_layout::LayoutRef>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait

pub trait vortex_layout::layouts::compressed::CompressorPlugin: core::marker::Send + core::marker::Sync + 'static

pub fn vortex_layout::layouts::compressed::CompressorPlugin::compress_chunk(&self, chunk: &vortex_array::array::erased::ArrayRef, ctx: &mut vortex_array::executor::ExecutionCtx) -> vortex_error::VortexResult<vortex_array::array::erased::ArrayRef>

impl vortex_layout::layouts::compressed::CompressorPlugin for alloc::sync::Arc<dyn vortex_layout::layouts::compressed::CompressorPlugin>

pub fn alloc::sync::Arc<dyn vortex_layout::layouts::compressed::CompressorPlugin>::compress_chunk(&self, chunk: &vortex_array::array::erased::ArrayRef, ctx: &mut vortex_array::executor::ExecutionCtx) -> vortex_error::VortexResult<vortex_array::array::erased::ArrayRef>

impl vortex_layout::layouts::compressed::CompressorPlugin for vortex_btrblocks::canonical_compressor::BtrBlocksCompressor

pub fn vortex_btrblocks::canonical_compressor::BtrBlocksCompressor::compress_chunk(&self, chunk: &vortex_array::array::erased::ArrayRef, ctx: &mut vortex_array::executor::ExecutionCtx) -> vortex_error::VortexResult<vortex_array::array::erased::ArrayRef>

impl<F> vortex_layout::layouts::compressed::CompressorPlugin for F where F: core::ops::function::Fn(&vortex_array::array::erased::ArrayRef, &mut vortex_array::executor::ExecutionCtx) -> vortex_error::VortexResult<vortex_array::array::erased::ArrayRef> + core::marker::Send + core::marker::Sync + 'static

pub fn F::compress_chunk(&self, chunk: &vortex_array::array::erased::ArrayRef, ctx: &mut vortex_array::executor::ExecutionCtx) -> vortex_error::VortexResult<vortex_array::array::erased::ArrayRef>

pub mod vortex_layout::layouts::dict

pub mod vortex_layout::layouts::dict::writer

pub struct vortex_layout::layouts::dict::writer::DictLayoutConstraints

pub vortex_layout::layouts::dict::writer::DictLayoutConstraints::max_bytes: usize

pub vortex_layout::layouts::dict::writer::DictLayoutConstraints::max_len: u16

impl core::clone::Clone for vortex_layout::layouts::dict::writer::DictLayoutConstraints

pub fn vortex_layout::layouts::dict::writer::DictLayoutConstraints::clone(&self) -> vortex_layout::layouts::dict::writer::DictLayoutConstraints

impl core::convert::From<vortex_layout::layouts::dict::writer::DictLayoutConstraints> for vortex_array::builders::dict::DictConstraints

pub fn vortex_array::builders::dict::DictConstraints::from(value: vortex_layout::layouts::dict::writer::DictLayoutConstraints) -> Self

impl core::default::Default for vortex_layout::layouts::dict::writer::DictLayoutConstraints

pub fn vortex_layout::layouts::dict::writer::DictLayoutConstraints::default() -> Self

pub struct vortex_layout::layouts::dict::writer::DictLayoutMetadata

impl vortex_layout::layouts::dict::writer::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::writer::DictLayoutMetadata::codes_ptype(&self) -> vortex_array::dtype::ptype::PType

pub fn vortex_layout::layouts::dict::writer::DictLayoutMetadata::set_codes_ptype(&mut self, value: vortex_array::dtype::ptype::PType)

impl vortex_layout::layouts::dict::writer::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::writer::DictLayoutMetadata::new(codes_ptype: vortex_array::dtype::ptype::PType) -> Self

impl core::default::Default for vortex_layout::layouts::dict::writer::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::writer::DictLayoutMetadata::default() -> Self

impl core::fmt::Debug for vortex_layout::layouts::dict::writer::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::writer::DictLayoutMetadata::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl prost::message::Message for vortex_layout::layouts::dict::writer::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::writer::DictLayoutMetadata::clear(&mut self)

pub fn vortex_layout::layouts::dict::writer::DictLayoutMetadata::encoded_len(&self) -> usize

pub struct vortex_layout::layouts::dict::writer::DictLayoutOptions

pub vortex_layout::layouts::dict::writer::DictLayoutOptions::constraints: vortex_layout::layouts::dict::writer::DictLayoutConstraints

impl core::clone::Clone for vortex_layout::layouts::dict::writer::DictLayoutOptions

pub fn vortex_layout::layouts::dict::writer::DictLayoutOptions::clone(&self) -> vortex_layout::layouts::dict::writer::DictLayoutOptions

impl core::default::Default for vortex_layout::layouts::dict::writer::DictLayoutOptions

pub fn vortex_layout::layouts::dict::writer::DictLayoutOptions::default() -> vortex_layout::layouts::dict::writer::DictLayoutOptions

pub struct vortex_layout::layouts::dict::writer::DictStrategy

impl vortex_layout::layouts::dict::writer::DictStrategy

pub fn vortex_layout::layouts::dict::writer::DictStrategy::new<Codes: vortex_layout::LayoutStrategy, Values: vortex_layout::LayoutStrategy, Fallback: vortex_layout::LayoutStrategy>(codes: Codes, values: Values, fallback: Fallback, options: vortex_layout::layouts::dict::writer::DictLayoutOptions) -> Self

impl core::clone::Clone for vortex_layout::layouts::dict::writer::DictStrategy

pub fn vortex_layout::layouts::dict::writer::DictStrategy::clone(&self) -> vortex_layout::layouts::dict::writer::DictStrategy

impl vortex_layout::LayoutStrategy for vortex_layout::layouts::dict::writer::DictStrategy

pub fn vortex_layout::layouts::dict::writer::DictStrategy::buffered_bytes(&self) -> u64

pub fn vortex_layout::layouts::dict::writer::DictStrategy::write_stream<'life0, 'life1, 'async_trait>(&'life0 self, ctx: vortex_array::ArrayContext, segment_sink: vortex_layout::segments::SegmentSinkRef, stream: vortex_layout::sequence::SendableSequentialStream, eof: vortex_layout::sequence::SequencePointer, session: &'life1 vortex_session::VortexSession) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = vortex_error::VortexResult<vortex_layout::LayoutRef>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait

pub fn vortex_layout::layouts::dict::writer::dict_layout_supported(dtype: &vortex_array::dtype::DType) -> bool

pub struct vortex_layout::layouts::dict::Dict

impl core::fmt::Debug for vortex_layout::layouts::dict::Dict

pub fn vortex_layout::layouts::dict::Dict::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl vortex_layout::VTable for vortex_layout::layouts::dict::Dict

pub type vortex_layout::layouts::dict::Dict::Encoding = vortex_layout::layouts::dict::DictLayoutEncoding

pub type vortex_layout::layouts::dict::Dict::Layout = vortex_layout::layouts::dict::DictLayout

pub type vortex_layout::layouts::dict::Dict::Metadata = vortex_array::metadata::ProstMetadata<vortex_layout::layouts::dict::DictLayoutMetadata>

pub fn vortex_layout::layouts::dict::Dict::build(_encoding: &Self::Encoding, dtype: &vortex_array::dtype::DType, _row_count: u64, metadata: &<Self::Metadata as vortex_array::metadata::DeserializeMetadata>::Output, _segment_ids: alloc::vec::Vec<vortex_layout::segments::SegmentId>, children: &dyn vortex_layout::LayoutChildren, _ctx: &vortex_session::registry::ReadContext) -> vortex_error::VortexResult<Self::Layout>

pub fn vortex_layout::layouts::dict::Dict::child(layout: &Self::Layout, idx: usize) -> vortex_error::VortexResult<vortex_layout::LayoutRef>

pub fn vortex_layout::layouts::dict::Dict::child_type(_layout: &Self::Layout, idx: usize) -> vortex_layout::LayoutChildType

pub fn vortex_layout::layouts::dict::Dict::dtype(layout: &Self::Layout) -> &vortex_array::dtype::DType

pub fn vortex_layout::layouts::dict::Dict::encoding(_layout: &Self::Layout) -> vortex_layout::LayoutEncodingRef

pub fn vortex_layout::layouts::dict::Dict::id(_encoding: &Self::Encoding) -> vortex_layout::LayoutId

pub fn vortex_layout::layouts::dict::Dict::metadata(layout: &Self::Layout) -> Self::Metadata

pub fn vortex_layout::layouts::dict::Dict::nchildren(_layout: &Self::Layout) -> usize

pub fn vortex_layout::layouts::dict::Dict::new_reader(layout: &Self::Layout, name: alloc::sync::Arc<str>, segment_source: alloc::sync::Arc<dyn vortex_layout::segments::SegmentSource>, session: &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_layout::LayoutReaderRef>

pub fn vortex_layout::layouts::dict::Dict::row_count(layout: &Self::Layout) -> u64

pub fn vortex_layout::layouts::dict::Dict::segment_ids(_layout: &Self::Layout) -> alloc::vec::Vec<vortex_layout::segments::SegmentId>

pub fn vortex_layout::layouts::dict::Dict::with_children(layout: &mut Self::Layout, children: alloc::vec::Vec<vortex_layout::LayoutRef>) -> vortex_error::VortexResult<()>

pub struct vortex_layout::layouts::dict::DictLayout

impl vortex_layout::layouts::dict::DictLayout

pub fn vortex_layout::layouts::dict::DictLayout::has_all_values_referenced(&self) -> bool

pub unsafe fn vortex_layout::layouts::dict::DictLayout::set_all_values_referenced(self, all_values_referenced: bool) -> Self

impl core::clone::Clone for vortex_layout::layouts::dict::DictLayout

pub fn vortex_layout::layouts::dict::DictLayout::clone(&self) -> vortex_layout::layouts::dict::DictLayout

impl core::convert::AsRef<dyn vortex_layout::Layout> for vortex_layout::layouts::dict::DictLayout

pub fn vortex_layout::layouts::dict::DictLayout::as_ref(&self) -> &dyn vortex_layout::Layout

impl core::convert::From<vortex_layout::layouts::dict::DictLayout> for vortex_layout::LayoutRef

pub fn vortex_layout::LayoutRef::from(value: vortex_layout::layouts::dict::DictLayout) -> vortex_layout::LayoutRef

impl core::fmt::Debug for vortex_layout::layouts::dict::DictLayout

pub fn vortex_layout::layouts::dict::DictLayout::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::dict::DictLayout

pub type vortex_layout::layouts::dict::DictLayout::Target = dyn vortex_layout::Layout

pub fn vortex_layout::layouts::dict::DictLayout::deref(&self) -> &Self::Target

impl vortex_layout::IntoLayout for vortex_layout::layouts::dict::DictLayout

pub fn vortex_layout::layouts::dict::DictLayout::into_layout(self) -> vortex_layout::LayoutRef

pub struct vortex_layout::layouts::dict::DictLayoutEncoding

impl core::convert::AsRef<dyn vortex_layout::LayoutEncoding> for vortex_layout::layouts::dict::DictLayoutEncoding

pub fn vortex_layout::layouts::dict::DictLayoutEncoding::as_ref(&self) -> &dyn vortex_layout::LayoutEncoding

impl core::fmt::Debug for vortex_layout::layouts::dict::DictLayoutEncoding

pub fn vortex_layout::layouts::dict::DictLayoutEncoding::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::dict::DictLayoutEncoding

pub type vortex_layout::layouts::dict::DictLayoutEncoding::Target = dyn vortex_layout::LayoutEncoding

pub fn vortex_layout::layouts::dict::DictLayoutEncoding::deref(&self) -> &Self::Target

pub struct vortex_layout::layouts::dict::DictLayoutMetadata

impl vortex_layout::layouts::dict::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::DictLayoutMetadata::all_values_referenced(&self) -> bool

pub fn vortex_layout::layouts::dict::DictLayoutMetadata::codes_ptype(&self) -> vortex_array::dtype::ptype::PType

pub fn vortex_layout::layouts::dict::DictLayoutMetadata::is_nullable_codes(&self) -> bool

pub fn vortex_layout::layouts::dict::DictLayoutMetadata::set_codes_ptype(&mut self, value: vortex_array::dtype::ptype::PType)

impl vortex_layout::layouts::dict::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::DictLayoutMetadata::new(codes_ptype: vortex_array::dtype::ptype::PType) -> Self

impl core::default::Default for vortex_layout::layouts::dict::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::DictLayoutMetadata::default() -> Self

impl core::fmt::Debug for vortex_layout::layouts::dict::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::DictLayoutMetadata::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl prost::message::Message for vortex_layout::layouts::dict::DictLayoutMetadata

pub fn vortex_layout::layouts::dict::DictLayoutMetadata::clear(&mut self)

pub fn vortex_layout::layouts::dict::DictLayoutMetadata::encoded_len(&self) -> usize

pub mod vortex_layout::layouts::file_stats

pub struct vortex_layout::layouts::file_stats::FileStatsAccumulator

impl vortex_layout::layouts::file_stats::FileStatsAccumulator

pub fn vortex_layout::layouts::file_stats::FileStatsAccumulator::stats_sets(&self) -> alloc::vec::Vec<vortex_array::stats::stats_set::StatsSet>

impl core::clone::Clone for vortex_layout::layouts::file_stats::FileStatsAccumulator

pub fn vortex_layout::layouts::file_stats::FileStatsAccumulator::clone(&self) -> vortex_layout::layouts::file_stats::FileStatsAccumulator

pub fn vortex_layout::layouts::file_stats::accumulate_stats(stream: vortex_layout::sequence::SendableSequentialStream, stats: alloc::sync::Arc<[vortex_array::expr::stats::Stat]>, max_variable_length_statistics_size: usize, session: &vortex_session::VortexSession) -> (vortex_layout::layouts::file_stats::FileStatsAccumulator, vortex_layout::sequence::SendableSequentialStream)

pub mod vortex_layout::layouts::flat

pub mod vortex_layout::layouts::flat::writer

pub struct vortex_layout::layouts::flat::writer::FlatLayoutStrategy

pub vortex_layout::layouts::flat::writer::FlatLayoutStrategy::allowed_encodings: core::option::Option<vortex_utils::aliases::hash_set::HashSet<vortex_array::array::ArrayId>>

pub vortex_layout::layouts::flat::writer::FlatLayoutStrategy::include_padding: bool

pub vortex_layout::layouts::flat::writer::FlatLayoutStrategy::max_variable_length_statistics_size: usize

impl vortex_layout::layouts::flat::writer::FlatLayoutStrategy

pub fn vortex_layout::layouts::flat::writer::FlatLayoutStrategy::with_allow_encodings(self, allow_encodings: vortex_utils::aliases::hash_set::HashSet<vortex_array::array::ArrayId>) -> Self

pub fn vortex_layout::layouts::flat::writer::FlatLayoutStrategy::with_include_padding(self, include_padding: bool) -> Self

pub fn vortex_layout::layouts::flat::writer::FlatLayoutStrategy::with_max_variable_length_statistics_size(self, size: usize) -> Self

impl core::clone::Clone for vortex_layout::layouts::flat::writer::FlatLayoutStrategy

pub fn vortex_layout::layouts::flat::writer::FlatLayoutStrategy::clone(&self) -> vortex_layout::layouts::flat::writer::FlatLayoutStrategy

impl core::default::Default for vortex_layout::layouts::flat::writer::FlatLayoutStrategy

pub fn vortex_layout::layouts::flat::writer::FlatLayoutStrategy::default() -> Self

impl vortex_layout::LayoutStrategy for vortex_layout::layouts::flat::writer::FlatLayoutStrategy

pub fn vortex_layout::layouts::flat::writer::FlatLayoutStrategy::buffered_bytes(&self) -> u64

pub fn vortex_layout::layouts::flat::writer::FlatLayoutStrategy::write_stream<'life0, 'life1, 'async_trait>(&'life0 self, ctx: vortex_array::ArrayContext, segment_sink: vortex_layout::segments::SegmentSinkRef, stream: vortex_layout::sequence::SendableSequentialStream, _eof: vortex_layout::sequence::SequencePointer, session: &'life1 vortex_session::VortexSession) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = vortex_error::VortexResult<vortex_layout::LayoutRef>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait

pub struct vortex_layout::layouts::flat::Flat

impl core::fmt::Debug for vortex_layout::layouts::flat::Flat

pub fn vortex_layout::layouts::flat::Flat::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl vortex_layout::VTable for vortex_layout::layouts::flat::Flat

pub type vortex_layout::layouts::flat::Flat::Encoding = vortex_layout::layouts::flat::FlatLayoutEncoding

pub type vortex_layout::layouts::flat::Flat::Layout = vortex_layout::layouts::flat::FlatLayout

pub type vortex_layout::layouts::flat::Flat::Metadata = vortex_array::metadata::ProstMetadata<vortex_layout::layouts::flat::FlatLayoutMetadata>

pub fn vortex_layout::layouts::flat::Flat::build(_encoding: &Self::Encoding, dtype: &vortex_array::dtype::DType, row_count: u64, metadata: &<Self::Metadata as vortex_array::metadata::DeserializeMetadata>::Output, segment_ids: alloc::vec::Vec<vortex_layout::segments::SegmentId>, _children: &dyn vortex_layout::LayoutChildren, ctx: &vortex_session::registry::ReadContext) -> vortex_error::VortexResult<Self::Layout>

pub fn vortex_layout::layouts::flat::Flat::child(_layout: &Self::Layout, _idx: usize) -> vortex_error::VortexResult<vortex_layout::LayoutRef>

pub fn vortex_layout::layouts::flat::Flat::child_type(_layout: &Self::Layout, _idx: usize) -> vortex_layout::LayoutChildType

pub fn vortex_layout::layouts::flat::Flat::dtype(layout: &Self::Layout) -> &vortex_array::dtype::DType

pub fn vortex_layout::layouts::flat::Flat::encoding(_layout: &Self::Layout) -> vortex_layout::LayoutEncodingRef

pub fn vortex_layout::layouts::flat::Flat::id(_encoding: &Self::Encoding) -> vortex_layout::LayoutId

pub fn vortex_layout::layouts::flat::Flat::metadata(layout: &Self::Layout) -> Self::Metadata

pub fn vortex_layout::layouts::flat::Flat::nchildren(_layout: &Self::Layout) -> usize

pub fn vortex_layout::layouts::flat::Flat::new_reader(layout: &Self::Layout, name: alloc::sync::Arc<str>, segment_source: alloc::sync::Arc<dyn vortex_layout::segments::SegmentSource>, session: &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_layout::LayoutReaderRef>

pub fn vortex_layout::layouts::flat::Flat::row_count(layout: &Self::Layout) -> u64

pub fn vortex_layout::layouts::flat::Flat::segment_ids(layout: &Self::Layout) -> alloc::vec::Vec<vortex_layout::segments::SegmentId>

pub fn vortex_layout::layouts::flat::Flat::with_children(_layout: &mut Self::Layout, children: alloc::vec::Vec<vortex_layout::LayoutRef>) -> vortex_error::VortexResult<()>

pub struct vortex_layout::layouts::flat::FlatLayout

impl vortex_layout::layouts::flat::FlatLayout

pub fn vortex_layout::layouts::flat::FlatLayout::array_ctx(&self) -> &vortex_session::registry::ReadContext

pub fn vortex_layout::layouts::flat::FlatLayout::array_tree(&self) -> core::option::Option<&vortex_buffer::ByteBuffer>

pub fn vortex_layout::layouts::flat::FlatLayout::new(row_count: u64, dtype: vortex_array::dtype::DType, segment_id: vortex_layout::segments::SegmentId, ctx: vortex_session::registry::ReadContext) -> Self

pub fn vortex_layout::layouts::flat::FlatLayout::new_with_metadata(row_count: u64, dtype: vortex_array::dtype::DType, segment_id: vortex_layout::segments::SegmentId, ctx: vortex_session::registry::ReadContext, metadata: core::option::Option<vortex_buffer::ByteBuffer>) -> Self

pub fn vortex_layout::layouts::flat::FlatLayout::segment_id(&self) -> vortex_layout::segments::SegmentId

impl core::clone::Clone for vortex_layout::layouts::flat::FlatLayout

pub fn vortex_layout::layouts::flat::FlatLayout::clone(&self) -> vortex_layout::layouts::flat::FlatLayout

impl core::convert::AsRef<dyn vortex_layout::Layout> for vortex_layout::layouts::flat::FlatLayout

pub fn vortex_layout::layouts::flat::FlatLayout::as_ref(&self) -> &dyn vortex_layout::Layout

impl core::convert::From<vortex_layout::layouts::flat::FlatLayout> for vortex_layout::LayoutRef

pub fn vortex_layout::LayoutRef::from(value: vortex_layout::layouts::flat::FlatLayout) -> vortex_layout::LayoutRef

impl core::fmt::Debug for vortex_layout::layouts::flat::FlatLayout

pub fn vortex_layout::layouts::flat::FlatLayout::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::flat::FlatLayout

pub type vortex_layout::layouts::flat::FlatLayout::Target = dyn vortex_layout::Layout

pub fn vortex_layout::layouts::flat::FlatLayout::deref(&self) -> &Self::Target

impl vortex_layout::IntoLayout for vortex_layout::layouts::flat::FlatLayout

pub fn vortex_layout::layouts::flat::FlatLayout::into_layout(self) -> vortex_layout::LayoutRef

pub struct vortex_layout::layouts::flat::FlatLayoutEncoding

impl core::convert::AsRef<dyn vortex_layout::LayoutEncoding> for vortex_layout::layouts::flat::FlatLayoutEncoding

pub fn vortex_layout::layouts::flat::FlatLayoutEncoding::as_ref(&self) -> &dyn vortex_layout::LayoutEncoding

impl core::fmt::Debug for vortex_layout::layouts::flat::FlatLayoutEncoding

pub fn vortex_layout::layouts::flat::FlatLayoutEncoding::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::flat::FlatLayoutEncoding

pub type vortex_layout::layouts::flat::FlatLayoutEncoding::Target = dyn vortex_layout::LayoutEncoding

pub fn vortex_layout::layouts::flat::FlatLayoutEncoding::deref(&self) -> &Self::Target

pub struct vortex_layout::layouts::flat::FlatLayoutMetadata

pub vortex_layout::layouts::flat::FlatLayoutMetadata::array_encoding_tree: core::option::Option<alloc::vec::Vec<u8>>

impl vortex_layout::layouts::flat::FlatLayoutMetadata

pub fn vortex_layout::layouts::flat::FlatLayoutMetadata::array_encoding_tree(&self) -> &[u8]

impl core::default::Default for vortex_layout::layouts::flat::FlatLayoutMetadata

pub fn vortex_layout::layouts::flat::FlatLayoutMetadata::default() -> Self

impl core::fmt::Debug for vortex_layout::layouts::flat::FlatLayoutMetadata

pub fn vortex_layout::layouts::flat::FlatLayoutMetadata::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl prost::message::Message for vortex_layout::layouts::flat::FlatLayoutMetadata

pub fn vortex_layout::layouts::flat::FlatLayoutMetadata::clear(&mut self)

pub fn vortex_layout::layouts::flat::FlatLayoutMetadata::encoded_len(&self) -> usize

pub mod vortex_layout::layouts::repartition

pub struct vortex_layout::layouts::repartition::RepartitionStrategy

impl vortex_layout::layouts::repartition::RepartitionStrategy

pub fn vortex_layout::layouts::repartition::RepartitionStrategy::new<S: vortex_layout::LayoutStrategy>(child: S, options: vortex_layout::layouts::repartition::RepartitionWriterOptions) -> Self

impl core::clone::Clone for vortex_layout::layouts::repartition::RepartitionStrategy

pub fn vortex_layout::layouts::repartition::RepartitionStrategy::clone(&self) -> vortex_layout::layouts::repartition::RepartitionStrategy

impl vortex_layout::LayoutStrategy for vortex_layout::layouts::repartition::RepartitionStrategy

pub fn vortex_layout::layouts::repartition::RepartitionStrategy::buffered_bytes(&self) -> u64

pub fn vortex_layout::layouts::repartition::RepartitionStrategy::write_stream<'life0, 'life1, 'async_trait>(&'life0 self, ctx: vortex_array::ArrayContext, segment_sink: vortex_layout::segments::SegmentSinkRef, stream: vortex_layout::sequence::SendableSequentialStream, eof: vortex_layout::sequence::SequencePointer, session: &'life1 vortex_session::VortexSession) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = vortex_error::VortexResult<vortex_layout::LayoutRef>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait

pub struct vortex_layout::layouts::repartition::RepartitionWriterOptions

pub vortex_layout::layouts::repartition::RepartitionWriterOptions::block_len_multiple: usize

pub vortex_layout::layouts::repartition::RepartitionWriterOptions::block_size_minimum: u64

pub vortex_layout::layouts::repartition::RepartitionWriterOptions::block_size_target: core::option::Option<u64>

pub vortex_layout::layouts::repartition::RepartitionWriterOptions::canonicalize: bool

impl core::clone::Clone for vortex_layout::layouts::repartition::RepartitionWriterOptions

pub fn vortex_layout::layouts::repartition::RepartitionWriterOptions::clone(&self) -> vortex_layout::layouts::repartition::RepartitionWriterOptions

pub mod vortex_layout::layouts::row_idx

pub struct vortex_layout::layouts::row_idx::RowIdx

impl core::clone::Clone for vortex_layout::layouts::row_idx::RowIdx

pub fn vortex_layout::layouts::row_idx::RowIdx::clone(&self) -> vortex_layout::layouts::row_idx::RowIdx

impl vortex_array::scalar_fn::vtable::ScalarFnVTable for vortex_layout::layouts::row_idx::RowIdx

pub type vortex_layout::layouts::row_idx::RowIdx::Options = vortex_array::scalar_fn::vtable::EmptyOptions

pub fn vortex_layout::layouts::row_idx::RowIdx::arity(&self, _options: &Self::Options) -> vortex_array::scalar_fn::vtable::Arity

pub fn vortex_layout::layouts::row_idx::RowIdx::child_name(&self, _instance: &Self::Options, _child_idx: usize) -> vortex_array::scalar_fn::vtable::ChildName

pub fn vortex_layout::layouts::row_idx::RowIdx::execute(&self, _options: &Self::Options, _args: &dyn vortex_array::scalar_fn::vtable::ExecutionArgs, _ctx: &mut vortex_array::executor::ExecutionCtx) -> vortex_error::VortexResult<vortex_array::array::erased::ArrayRef>

pub fn vortex_layout::layouts::row_idx::RowIdx::fmt_sql(&self, _options: &Self::Options, _expr: &vortex_array::expr::expression::Expression, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

pub fn vortex_layout::layouts::row_idx::RowIdx::id(&self) -> vortex_array::scalar_fn::ScalarFnId

pub fn vortex_layout::layouts::row_idx::RowIdx::return_dtype(&self, _options: &Self::Options, _arg_dtypes: &[vortex_array::dtype::DType]) -> vortex_error::VortexResult<vortex_array::dtype::DType>

pub struct vortex_layout::layouts::row_idx::RowIdxLayoutReader

impl vortex_layout::layouts::row_idx::RowIdxLayoutReader

pub fn vortex_layout::layouts::row_idx::RowIdxLayoutReader::new(row_offset: u64, child: alloc::sync::Arc<dyn vortex_layout::LayoutReader>, session: vortex_session::VortexSession) -> Self

impl vortex_layout::LayoutReader for vortex_layout::layouts::row_idx::RowIdxLayoutReader

pub fn vortex_layout::layouts::row_idx::RowIdxLayoutReader::as_any(&self) -> &dyn core::any::Any

pub fn vortex_layout::layouts::row_idx::RowIdxLayoutReader::dtype(&self) -> &vortex_array::dtype::DType

pub fn vortex_layout::layouts::row_idx::RowIdxLayoutReader::filter_evaluation(&self, row_range: &core::ops::range::Range<u64>, expr: &vortex_array::expr::expression::Expression, mask: vortex_array::mask_future::MaskFuture) -> vortex_error::VortexResult<vortex_array::mask_future::MaskFuture>

pub fn vortex_layout::layouts::row_idx::RowIdxLayoutReader::name(&self) -> &alloc::sync::Arc<str>

pub fn vortex_layout::layouts::row_idx::RowIdxLayoutReader::projection_evaluation(&self, row_range: &core::ops::range::Range<u64>, expr: &vortex_array::expr::expression::Expression, mask: vortex_array::mask_future::MaskFuture) -> vortex_error::VortexResult<futures_core::future::BoxFuture<'static, vortex_error::VortexResult<vortex_array::array::erased::ArrayRef>>>

pub fn vortex_layout::layouts::row_idx::RowIdxLayoutReader::pruning_evaluation(&self, row_range: &core::ops::range::Range<u64>, expr: &vortex_array::expr::expression::Expression, mask: vortex_mask::Mask) -> vortex_error::VortexResult<vortex_array::mask_future::MaskFuture>

pub fn vortex_layout::layouts::row_idx::RowIdxLayoutReader::register_splits(&self, field_mask: &[vortex_array::dtype::field_mask::FieldMask], row_range: &core::ops::range::Range<u64>, splits: &mut alloc::collections::btree::set::BTreeSet<u64>) -> vortex_error::VortexResult<()>

pub fn vortex_layout::layouts::row_idx::RowIdxLayoutReader::row_count(&self) -> u64

pub fn vortex_layout::layouts::row_idx::row_idx() -> vortex_array::expr::expression::Expression

pub mod vortex_layout::layouts::struct_

pub struct vortex_layout::layouts::struct_::Struct

impl core::fmt::Debug for vortex_layout::layouts::struct_::Struct

pub fn vortex_layout::layouts::struct_::Struct::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl vortex_layout::VTable for vortex_layout::layouts::struct_::Struct

pub type vortex_layout::layouts::struct_::Struct::Encoding = vortex_layout::layouts::struct_::StructLayoutEncoding

pub type vortex_layout::layouts::struct_::Struct::Layout = vortex_layout::layouts::struct_::StructLayout

pub type vortex_layout::layouts::struct_::Struct::Metadata = vortex_array::metadata::EmptyMetadata

pub fn vortex_layout::layouts::struct_::Struct::build(_encoding: &Self::Encoding, dtype: &vortex_array::dtype::DType, row_count: u64, _metadata: &<Self::Metadata as vortex_array::metadata::DeserializeMetadata>::Output, _segment_ids: alloc::vec::Vec<vortex_layout::segments::SegmentId>, children: &dyn vortex_layout::LayoutChildren, _ctx: &vortex_session::registry::ReadContext) -> vortex_error::VortexResult<Self::Layout>

pub fn vortex_layout::layouts::struct_::Struct::child(layout: &Self::Layout, index: usize) -> vortex_error::VortexResult<vortex_layout::LayoutRef>

pub fn vortex_layout::layouts::struct_::Struct::child_type(layout: &Self::Layout, idx: usize) -> vortex_layout::LayoutChildType

pub fn vortex_layout::layouts::struct_::Struct::dtype(layout: &Self::Layout) -> &vortex_array::dtype::DType

pub fn vortex_layout::layouts::struct_::Struct::encoding(_layout: &Self::Layout) -> vortex_layout::LayoutEncodingRef

pub fn vortex_layout::layouts::struct_::Struct::id(_encoding: &Self::Encoding) -> vortex_layout::LayoutId

pub fn vortex_layout::layouts::struct_::Struct::metadata(_layout: &Self::Layout) -> Self::Metadata

pub fn vortex_layout::layouts::struct_::Struct::nchildren(layout: &Self::Layout) -> usize

pub fn vortex_layout::layouts::struct_::Struct::new_reader(layout: &Self::Layout, name: alloc::sync::Arc<str>, segment_source: alloc::sync::Arc<dyn vortex_layout::segments::SegmentSource>, session: &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_layout::LayoutReaderRef>

pub fn vortex_layout::layouts::struct_::Struct::row_count(layout: &Self::Layout) -> u64

pub fn vortex_layout::layouts::struct_::Struct::segment_ids(_layout: &Self::Layout) -> alloc::vec::Vec<vortex_layout::segments::SegmentId>

pub fn vortex_layout::layouts::struct_::Struct::with_children(layout: &mut Self::Layout, children: alloc::vec::Vec<vortex_layout::LayoutRef>) -> vortex_error::VortexResult<()>

pub struct vortex_layout::layouts::struct_::StructLayout

impl vortex_layout::layouts::struct_::StructLayout

pub fn vortex_layout::layouts::struct_::StructLayout::children(&self) -> &alloc::sync::Arc<dyn vortex_layout::LayoutChildren>

pub fn vortex_layout::layouts::struct_::StructLayout::matching_fields<F>(&self, field_mask: &[vortex_array::dtype::field_mask::FieldMask], per_child: F) -> vortex_error::VortexResult<()> where F: core::ops::function::FnMut(vortex_array::dtype::field_mask::FieldMask, usize) -> vortex_error::VortexResult<()>

pub fn vortex_layout::layouts::struct_::StructLayout::new(row_count: u64, dtype: vortex_array::dtype::DType, children: alloc::vec::Vec<vortex_layout::LayoutRef>) -> Self

pub fn vortex_layout::layouts::struct_::StructLayout::row_count(&self) -> u64

pub fn vortex_layout::layouts::struct_::StructLayout::struct_fields(&self) -> &vortex_array::dtype::struct_::StructFields

impl core::clone::Clone for vortex_layout::layouts::struct_::StructLayout

pub fn vortex_layout::layouts::struct_::StructLayout::clone(&self) -> vortex_layout::layouts::struct_::StructLayout

impl core::convert::AsRef<dyn vortex_layout::Layout> for vortex_layout::layouts::struct_::StructLayout

pub fn vortex_layout::layouts::struct_::StructLayout::as_ref(&self) -> &dyn vortex_layout::Layout

impl core::convert::From<vortex_layout::layouts::struct_::StructLayout> for vortex_layout::LayoutRef

pub fn vortex_layout::LayoutRef::from(value: vortex_layout::layouts::struct_::StructLayout) -> vortex_layout::LayoutRef

impl core::fmt::Debug for vortex_layout::layouts::struct_::StructLayout

pub fn vortex_layout::layouts::struct_::StructLayout::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::struct_::StructLayout

pub type vortex_layout::layouts::struct_::StructLayout::Target = dyn vortex_layout::Layout

pub fn vortex_layout::layouts::struct_::StructLayout::deref(&self) -> &Self::Target

impl vortex_layout::IntoLayout for vortex_layout::layouts::struct_::StructLayout

pub fn vortex_layout::layouts::struct_::StructLayout::into_layout(self) -> vortex_layout::LayoutRef

pub struct vortex_layout::layouts::struct_::StructLayoutEncoding

impl core::convert::AsRef<dyn vortex_layout::LayoutEncoding> for vortex_layout::layouts::struct_::StructLayoutEncoding

pub fn vortex_layout::layouts::struct_::StructLayoutEncoding::as_ref(&self) -> &dyn vortex_layout::LayoutEncoding

impl core::fmt::Debug for vortex_layout::layouts::struct_::StructLayoutEncoding

pub fn vortex_layout::layouts::struct_::StructLayoutEncoding::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::struct_::StructLayoutEncoding

pub type vortex_layout::layouts::struct_::StructLayoutEncoding::Target = dyn vortex_layout::LayoutEncoding

pub fn vortex_layout::layouts::struct_::StructLayoutEncoding::deref(&self) -> &Self::Target

pub mod vortex_layout::layouts::table

pub struct vortex_layout::layouts::table::TableStrategy

impl vortex_layout::layouts::table::TableStrategy

pub fn vortex_layout::layouts::table::TableStrategy::new(validity: alloc::sync::Arc<dyn vortex_layout::LayoutStrategy>, fallback: alloc::sync::Arc<dyn vortex_layout::LayoutStrategy>) -> Self

pub fn vortex_layout::layouts::table::TableStrategy::with_default_strategy(self, default: alloc::sync::Arc<dyn vortex_layout::LayoutStrategy>) -> Self

pub fn vortex_layout::layouts::table::TableStrategy::with_field_writer(self, field_path: impl core::convert::Into<vortex_array::dtype::field::FieldPath>, writer: alloc::sync::Arc<dyn vortex_layout::LayoutStrategy>) -> Self

pub fn vortex_layout::layouts::table::TableStrategy::with_field_writers(self, writers: impl core::iter::traits::collect::IntoIterator<Item = (vortex_array::dtype::field::FieldPath, alloc::sync::Arc<dyn vortex_layout::LayoutStrategy>)>) -> Self

pub fn vortex_layout::layouts::table::TableStrategy::with_validity_strategy(self, validity: alloc::sync::Arc<dyn vortex_layout::LayoutStrategy>) -> Self

impl vortex_layout::LayoutStrategy for vortex_layout::layouts::table::TableStrategy

pub fn vortex_layout::layouts::table::TableStrategy::buffered_bytes(&self) -> u64

pub fn vortex_layout::layouts::table::TableStrategy::write_stream<'life0, 'life1, 'async_trait>(&'life0 self, ctx: vortex_array::ArrayContext, segment_sink: vortex_layout::segments::SegmentSinkRef, stream: vortex_layout::sequence::SendableSequentialStream, eof: vortex_layout::sequence::SequencePointer, session: &'life1 vortex_session::VortexSession) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = vortex_error::VortexResult<vortex_layout::LayoutRef>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait

pub mod vortex_layout::layouts::zoned

pub mod vortex_layout::layouts::zoned::writer

pub struct vortex_layout::layouts::zoned::writer::ZonedLayoutOptions

pub vortex_layout::layouts::zoned::writer::ZonedLayoutOptions::block_size: usize

pub vortex_layout::layouts::zoned::writer::ZonedLayoutOptions::concurrency: usize

pub vortex_layout::layouts::zoned::writer::ZonedLayoutOptions::max_variable_length_statistics_size: usize

pub vortex_layout::layouts::zoned::writer::ZonedLayoutOptions::stats: alloc::sync::Arc<[vortex_array::expr::stats::Stat]>

impl core::default::Default for vortex_layout::layouts::zoned::writer::ZonedLayoutOptions

pub fn vortex_layout::layouts::zoned::writer::ZonedLayoutOptions::default() -> Self

pub struct vortex_layout::layouts::zoned::writer::ZonedStrategy

impl vortex_layout::layouts::zoned::writer::ZonedStrategy

pub fn vortex_layout::layouts::zoned::writer::ZonedStrategy::new<Child: vortex_layout::LayoutStrategy, Stats: vortex_layout::LayoutStrategy>(child: Child, stats: Stats, options: vortex_layout::layouts::zoned::writer::ZonedLayoutOptions) -> Self

impl vortex_layout::LayoutStrategy for vortex_layout::layouts::zoned::writer::ZonedStrategy

pub fn vortex_layout::layouts::zoned::writer::ZonedStrategy::buffered_bytes(&self) -> u64

pub fn vortex_layout::layouts::zoned::writer::ZonedStrategy::write_stream<'life0, 'life1, 'async_trait>(&'life0 self, ctx: vortex_array::ArrayContext, segment_sink: vortex_layout::segments::SegmentSinkRef, stream: vortex_layout::sequence::SendableSequentialStream, eof: vortex_layout::sequence::SequencePointer, session: &'life1 vortex_session::VortexSession) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = vortex_error::VortexResult<vortex_layout::LayoutRef>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait

pub mod vortex_layout::layouts::zoned::zone_map

pub struct vortex_layout::layouts::zoned::zone_map::StatsAccumulator

impl vortex_layout::layouts::zoned::zone_map::StatsAccumulator

pub fn vortex_layout::layouts::zoned::zone_map::StatsAccumulator::as_stats_table(&mut self) -> vortex_error::VortexResult<core::option::Option<vortex_layout::layouts::zoned::zone_map::ZoneMap>>

pub fn vortex_layout::layouts::zoned::zone_map::StatsAccumulator::new(dtype: &vortex_array::dtype::DType, stats: &[vortex_array::expr::stats::Stat], max_variable_length_statistics_size: usize) -> Self

pub fn vortex_layout::layouts::zoned::zone_map::StatsAccumulator::push_chunk(&mut self, array: &vortex_array::array::erased::ArrayRef, ctx: &mut vortex_array::executor::ExecutionCtx) -> vortex_error::VortexResult<()>

pub fn vortex_layout::layouts::zoned::zone_map::StatsAccumulator::push_chunk_without_compute(&mut self, array: &vortex_array::array::erased::ArrayRef) -> vortex_error::VortexResult<()>

pub struct vortex_layout::layouts::zoned::zone_map::ZoneMap

impl vortex_layout::layouts::zoned::zone_map::ZoneMap

pub fn vortex_layout::layouts::zoned::zone_map::ZoneMap::array(&self) -> &vortex_array::arrays::struct_::vtable::StructArray

pub fn vortex_layout::layouts::zoned::zone_map::ZoneMap::dtype_for_stats_table(column_dtype: &vortex_array::dtype::DType, present_stats: &[vortex_array::expr::stats::Stat]) -> vortex_array::dtype::DType

pub fn vortex_layout::layouts::zoned::zone_map::ZoneMap::get_stat(&self, stat: vortex_array::expr::stats::Stat) -> vortex_error::VortexResult<core::option::Option<vortex_array::array::erased::ArrayRef>>

pub unsafe fn vortex_layout::layouts::zoned::zone_map::ZoneMap::new_unchecked(array: vortex_array::arrays::struct_::vtable::StructArray, stats: alloc::sync::Arc<[vortex_array::expr::stats::Stat]>) -> Self

pub fn vortex_layout::layouts::zoned::zone_map::ZoneMap::present_stats(&self) -> &alloc::sync::Arc<[vortex_array::expr::stats::Stat]>

pub fn vortex_layout::layouts::zoned::zone_map::ZoneMap::prune(&self, predicate: &vortex_array::expr::expression::Expression, session: &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_mask::Mask>

pub fn vortex_layout::layouts::zoned::zone_map::ZoneMap::to_stats_set(&self, stats: &[vortex_array::expr::stats::Stat], ctx: &mut vortex_array::executor::ExecutionCtx) -> vortex_error::VortexResult<vortex_array::stats::stats_set::StatsSet>

pub fn vortex_layout::layouts::zoned::zone_map::ZoneMap::try_new(column_dtype: vortex_array::dtype::DType, array: vortex_array::arrays::struct_::vtable::StructArray, stats: alloc::sync::Arc<[vortex_array::expr::stats::Stat]>) -> vortex_error::VortexResult<Self>

impl core::clone::Clone for vortex_layout::layouts::zoned::zone_map::ZoneMap

pub fn vortex_layout::layouts::zoned::zone_map::ZoneMap::clone(&self) -> vortex_layout::layouts::zoned::zone_map::ZoneMap

pub struct vortex_layout::layouts::zoned::Zoned

impl core::fmt::Debug for vortex_layout::layouts::zoned::Zoned

pub fn vortex_layout::layouts::zoned::Zoned::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl vortex_layout::VTable for vortex_layout::layouts::zoned::Zoned

pub type vortex_layout::layouts::zoned::Zoned::Encoding = vortex_layout::layouts::zoned::ZonedLayoutEncoding

pub type vortex_layout::layouts::zoned::Zoned::Layout = vortex_layout::layouts::zoned::ZonedLayout

pub type vortex_layout::layouts::zoned::Zoned::Metadata = vortex_layout::layouts::zoned::ZonedMetadata

pub fn vortex_layout::layouts::zoned::Zoned::build(_encoding: &Self::Encoding, dtype: &vortex_array::dtype::DType, _row_count: u64, metadata: &vortex_layout::layouts::zoned::ZonedMetadata, _segment_ids: alloc::vec::Vec<vortex_layout::segments::SegmentId>, children: &dyn vortex_layout::LayoutChildren, _ctx: &vortex_session::registry::ReadContext) -> vortex_error::VortexResult<Self::Layout>

pub fn vortex_layout::layouts::zoned::Zoned::child(layout: &Self::Layout, idx: usize) -> vortex_error::VortexResult<vortex_layout::LayoutRef>

pub fn vortex_layout::layouts::zoned::Zoned::child_type(_layout: &Self::Layout, idx: usize) -> vortex_layout::LayoutChildType

pub fn vortex_layout::layouts::zoned::Zoned::dtype(layout: &Self::Layout) -> &vortex_array::dtype::DType

pub fn vortex_layout::layouts::zoned::Zoned::encoding(_layout: &Self::Layout) -> vortex_layout::LayoutEncodingRef

pub fn vortex_layout::layouts::zoned::Zoned::id(_encoding: &Self::Encoding) -> vortex_layout::LayoutId

pub fn vortex_layout::layouts::zoned::Zoned::metadata(layout: &Self::Layout) -> Self::Metadata

pub fn vortex_layout::layouts::zoned::Zoned::nchildren(_layout: &Self::Layout) -> usize

pub fn vortex_layout::layouts::zoned::Zoned::new_reader(layout: &Self::Layout, name: alloc::sync::Arc<str>, segment_source: alloc::sync::Arc<dyn vortex_layout::segments::SegmentSource>, session: &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_layout::LayoutReaderRef>

pub fn vortex_layout::layouts::zoned::Zoned::row_count(layout: &Self::Layout) -> u64

pub fn vortex_layout::layouts::zoned::Zoned::segment_ids(_layout: &Self::Layout) -> alloc::vec::Vec<vortex_layout::segments::SegmentId>

pub fn vortex_layout::layouts::zoned::Zoned::with_children(layout: &mut Self::Layout, children: alloc::vec::Vec<vortex_layout::LayoutRef>) -> vortex_error::VortexResult<()>

pub struct vortex_layout::layouts::zoned::ZonedLayout

impl vortex_layout::layouts::zoned::ZonedLayout

pub fn vortex_layout::layouts::zoned::ZonedLayout::new(data: vortex_layout::LayoutRef, zones: vortex_layout::LayoutRef, zone_len: usize, present_stats: alloc::sync::Arc<[vortex_array::expr::stats::Stat]>) -> Self

pub fn vortex_layout::layouts::zoned::ZonedLayout::nzones(&self) -> usize

pub fn vortex_layout::layouts::zoned::ZonedLayout::present_stats(&self) -> &alloc::sync::Arc<[vortex_array::expr::stats::Stat]>

impl core::clone::Clone for vortex_layout::layouts::zoned::ZonedLayout

pub fn vortex_layout::layouts::zoned::ZonedLayout::clone(&self) -> vortex_layout::layouts::zoned::ZonedLayout

impl core::convert::AsRef<dyn vortex_layout::Layout> for vortex_layout::layouts::zoned::ZonedLayout

pub fn vortex_layout::layouts::zoned::ZonedLayout::as_ref(&self) -> &dyn vortex_layout::Layout

impl core::convert::From<vortex_layout::layouts::zoned::ZonedLayout> for vortex_layout::LayoutRef

pub fn vortex_layout::LayoutRef::from(value: vortex_layout::layouts::zoned::ZonedLayout) -> vortex_layout::LayoutRef

impl core::fmt::Debug for vortex_layout::layouts::zoned::ZonedLayout

pub fn vortex_layout::layouts::zoned::ZonedLayout::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::zoned::ZonedLayout

pub type vortex_layout::layouts::zoned::ZonedLayout::Target = dyn vortex_layout::Layout

pub fn vortex_layout::layouts::zoned::ZonedLayout::deref(&self) -> &Self::Target

impl vortex_layout::IntoLayout for vortex_layout::layouts::zoned::ZonedLayout

pub fn vortex_layout::layouts::zoned::ZonedLayout::into_layout(self) -> vortex_layout::LayoutRef

pub struct vortex_layout::layouts::zoned::ZonedLayoutEncoding

impl core::convert::AsRef<dyn vortex_layout::LayoutEncoding> for vortex_layout::layouts::zoned::ZonedLayoutEncoding

pub fn vortex_layout::layouts::zoned::ZonedLayoutEncoding::as_ref(&self) -> &dyn vortex_layout::LayoutEncoding

impl core::fmt::Debug for vortex_layout::layouts::zoned::ZonedLayoutEncoding

pub fn vortex_layout::layouts::zoned::ZonedLayoutEncoding::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::ops::deref::Deref for vortex_layout::layouts::zoned::ZonedLayoutEncoding

pub type vortex_layout::layouts::zoned::ZonedLayoutEncoding::Target = dyn vortex_layout::LayoutEncoding

pub fn vortex_layout::layouts::zoned::ZonedLayoutEncoding::deref(&self) -> &Self::Target

pub struct vortex_layout::layouts::zoned::ZonedMetadata

impl core::clone::Clone for vortex_layout::layouts::zoned::ZonedMetadata

pub fn vortex_layout::layouts::zoned::ZonedMetadata::clone(&self) -> vortex_layout::layouts::zoned::ZonedMetadata

impl core::cmp::Eq for vortex_layout::layouts::zoned::ZonedMetadata

impl core::cmp::PartialEq for vortex_layout::layouts::zoned::ZonedMetadata

pub fn vortex_layout::layouts::zoned::ZonedMetadata::eq(&self, other: &vortex_layout::layouts::zoned::ZonedMetadata) -> bool

impl core::fmt::Debug for vortex_layout::layouts::zoned::ZonedMetadata

pub fn vortex_layout::layouts::zoned::ZonedMetadata::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result

impl core::marker::StructuralPartialEq for vortex_layout::layouts::zoned::ZonedMetadata

impl vortex_array::metadata::DeserializeMetadata for vortex_layout::layouts::zoned::ZonedMetadata

pub type vortex_layout::layouts::zoned::ZonedMetadata::Output = vortex_layout::layouts::zoned::ZonedMetadata

pub fn vortex_layout::layouts::zoned::ZonedMetadata::deserialize(metadata: &[u8]) -> vortex_error::VortexResult<Self::Output>

impl vortex_array::metadata::SerializeMetadata for vortex_layout::layouts::zoned::ZonedMetadata

pub fn vortex_layout::layouts::zoned::ZonedMetadata::serialize(self) -> alloc::vec::Vec<u8>

pub const vortex_layout::layouts::zoned::MAX_IS_TRUNCATED: &str

pub const vortex_layout::layouts::zoned::MIN_IS_TRUNCATED: &str

pub type vortex_layout::layouts::SharedArrayFuture = futures_util::future::future::shared::Shared<futures_core::future::BoxFuture<'static, vortex_error::SharedVortexResult<vortex_array::array::erased::ArrayRef>>>

pub mod vortex_layout::scan

pub mod vortex_layout::scan::arrow

pub struct vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I>

impl<I> vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I>

pub fn vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I>::new(iter: I, schema: arrow_schema::schema::SchemaRef) -> Self

impl<I: core::clone::Clone> core::clone::Clone for vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I>

pub fn vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I>::clone(&self) -> vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I>

impl<I> arrow_array::record_batch::RecordBatchReader for vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I> where I: core::iter::traits::iterator::Iterator<Item = core::result::Result<arrow_array::record_batch::RecordBatch, arrow_schema::error::ArrowError>>

pub fn vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I>::schema(&self) -> arrow_schema::schema::SchemaRef

impl<I> core::iter::traits::iterator::Iterator for vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I> where I: core::iter::traits::iterator::Iterator<Item = core::result::Result<arrow_array::record_batch::RecordBatch, arrow_schema::error::ArrowError>>

pub type vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I>::Item = core::result::Result<arrow_array::record_batch::RecordBatch, arrow_schema::error::ArrowError>

pub fn vortex_layout::scan::arrow::RecordBatchIteratorAdapter<I>::next(&mut self) -> core::option::Option<Self::Item>

pub mod vortex_layout::scan::layout

pub struct vortex_layout::scan::layout::LayoutReaderDataSource

impl vortex_layout::scan::layout::LayoutReaderDataSource

pub fn vortex_layout::scan::layout::LayoutReaderDataSource::new(reader: vortex_layout::LayoutReaderRef, session: vortex_session::VortexSession) -> Self

pub fn vortex_layout::scan::layout::LayoutReaderDataSource::with_metrics_registry(self, metrics: alloc::sync::Arc<dyn vortex_metrics::MetricsRegistry>) -> Self

pub fn vortex_layout::scan::layout::LayoutReaderDataSource::with_some_metrics_registry(self, metrics: core::option::Option<alloc::sync::Arc<dyn vortex_metrics::MetricsRegistry>>) -> Self

pub fn vortex_layout::scan::layout::LayoutReaderDataSource::with_split_max_row_count(self, row_count: u64) -> Self

impl vortex_scan::DataSource for vortex_layout::scan::layout::LayoutReaderDataSource

pub fn vortex_layout::scan::layout::LayoutReaderDataSource::byte_size(&self) -> core::option::Option<vortex_array::expr::stats::precision::Precision<u64>>

pub fn vortex_layout::scan::layout::LayoutReaderDataSource::deserialize_partition(&self, _data: &[u8], _session: &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_scan::PartitionRef>

pub fn vortex_layout::scan::layout::LayoutReaderDataSource::dtype(&self) -> &vortex_array::dtype::DType