Struct StructStrategy 

pub struct StructStrategy { /* private fields */ }

Writes struct-typed arrays into a StructLayout, one child layout per field.

Each field is written through a strategy resolved by direct field name: an entry in field_writers if present, otherwise default. When the struct is nullable, its validity bitmap is written through validity.

StructStrategy is intentionally unaware of nested dtypes and field-path overrides. To write arbitrarily nested struct trees with per-path overrides, drive it from TableStrategy, which dispatches on dtype and resolves the per-field child strategies before handing them here.

Implementations

impl StructStrategy

pub fn new( validity: Arc<dyn LayoutStrategy>, default: Arc<dyn LayoutStrategy>, ) -> Self

Create a new struct writer that writes every field through default and the validity bitmap (when present) through validity.

pub fn with_field_writer( self, name: impl Into<FieldName>, writer: Arc<dyn LayoutStrategy>, ) -> Self

Override the strategy for a single field by name.

pub fn with_field_writers( self, writers: impl IntoIterator<Item = (FieldName, Arc<dyn LayoutStrategy>)>, ) -> Self

Override the strategy for several fields by name at once.

Trait Implementations

impl Clone for StructStrategy

fn clone(&self) -> StructStrategy

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl LayoutStrategy for StructStrategy

fn write_stream<'life0, 'life1, 'async_trait>( &'life0 self, ctx: ArrayContext, segment_sink: SegmentSinkRef, stream: SendableSequentialStream, eof: SequencePointer, session: &'life1 VortexSession, ) -> Pin<Box<dyn Future<Output = VortexResult<LayoutRef>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Asynchronously process an ordered stream of array chunks, emitting them into a sink and returning the Layout instance that can be parsed to retrieve the data from rest.

fn buffered_bytes(&self) -> u64

Returns the number of bytes currently buffered by this strategy and any child strategies.