Skip to main content

ArrowArrayExecutor

vortex_array::arrow

Trait ArrowArrayExecutor 

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

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

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

Required Methods§

Source

fn execute_arrow( self, data_type: Option<&DataType>, ctx: &mut ExecutionCtx, ) -> 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. If None, the array’s preferred (cheapest) Arrow type will be used.

Source

fn execute_record_batches( self, schema: &Schema, ctx: &mut ExecutionCtx, ) -> 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, ctx: &mut ExecutionCtx, ) -> 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§