ArrowArrayExecutor

Trait ArrowArrayExecutor 

Source
pub trait ArrowArrayExecutor: Sized {
    // Required methods
    fn execute_arrow(
        self,
        data_type: &DataType,
        session: &VortexSession,
    ) -> VortexResult<ArrowArrayRef>;
    fn execute_record_batches(
        self,
        schema: &Schema,
        session: &VortexSession,
    ) -> VortexResult<Vec<RecordBatch>>;

    // Provided method
    fn execute_record_batch(
        self,
        schema: &Schema,
        session: &VortexSession,
    ) -> VortexResult<RecordBatch> { ... }
}
Expand description

Trait for executing a Vortex array to produce an Arrow array.

Required Methods§

Source

fn execute_arrow( self, data_type: &DataType, session: &VortexSession, ) -> VortexResult<ArrowArrayRef>

Execute the array to produce an Arrow array.

If a DataType is given, the array will be converted to the desired Arrow type.

Source

fn execute_record_batches( self, schema: &Schema, session: &VortexSession, ) -> VortexResult<Vec<RecordBatch>>

Execute the array to produce Arrow RecordBatch’s with the given schema.

Provided Methods§

Source

fn execute_record_batch( self, schema: &Schema, session: &VortexSession, ) -> VortexResult<RecordBatch>

Execute the array to produce an Arrow RecordBatch with the given schema.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§