pub struct MapStructuralEncoder { /* private fields */ }Expand description
A structural encoder for map fields
Map in Arrow is represented as List<Struct<key, value>> The map’s offsets are added to the rep/def builder and the map’s entries (struct array) are passed to the child encoder
Implementations§
Source§impl MapStructuralEncoder
impl MapStructuralEncoder
pub fn new(keep_original_array: bool, child: Box<dyn FieldEncoder>) -> Self
Trait Implementations§
Source§impl FieldEncoder for MapStructuralEncoder
impl FieldEncoder for MapStructuralEncoder
Source§fn maybe_encode(
&mut self,
array: ArrayRef,
external_buffers: &mut OutOfLineBuffers,
repdef: RepDefBuilder,
row_number: u64,
num_rows: u64,
) -> Result<Vec<EncodeTask>>
fn maybe_encode( &mut self, array: ArrayRef, external_buffers: &mut OutOfLineBuffers, repdef: RepDefBuilder, row_number: u64, num_rows: u64, ) -> Result<Vec<EncodeTask>>
Buffer the data and, if there is enough data in the buffer to form a page, return
an encoding task to encode the data. Read more
Source§fn flush(
&mut self,
external_buffers: &mut OutOfLineBuffers,
) -> Result<Vec<EncodeTask>>
fn flush( &mut self, external_buffers: &mut OutOfLineBuffers, ) -> Result<Vec<EncodeTask>>
Flush any remaining data from the buffers into encoding tasks Read more
Source§fn num_columns(&self) -> u32
fn num_columns(&self) -> u32
The number of output columns this encoding will create
Source§fn finish(
&mut self,
external_buffers: &mut OutOfLineBuffers,
) -> BoxFuture<'_, Result<Vec<EncodedColumn>>>
fn finish( &mut self, external_buffers: &mut OutOfLineBuffers, ) -> BoxFuture<'_, Result<Vec<EncodedColumn>>>
Finish encoding and return column metadata Read more
Auto Trait Implementations§
impl Freeze for MapStructuralEncoder
impl !RefUnwindSafe for MapStructuralEncoder
impl Send for MapStructuralEncoder
impl !Sync for MapStructuralEncoder
impl Unpin for MapStructuralEncoder
impl !UnwindSafe for MapStructuralEncoder
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more