Trait UdfFromArrow

pub trait UdfFromArrow {
    // Provided methods
    fn from_record_batch(
        &self,
        batch: &RecordBatch,
    ) -> Result<DataChunk, ArrayError> { ... }
    fn from_fields(&self, fields: &Fields) -> Result<StructType, ArrayError> { ... }
    fn from_field(&self, field: &Field) -> Result<DataType, ArrayError> { ... }
    fn from_large_utf8(&self) -> Result<DataType, ArrayError> { ... }
    fn from_large_binary(&self) -> Result<DataType, ArrayError> { ... }
    fn from_extension_type(
        &self,
        type_name: &str,
        physical_type: &DataType,
    ) -> Result<DataType, ArrayError> { ... }
    fn from_array(
        &self,
        field: &Field,
        array: &ArrayRef,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_extension_array(
        &self,
        type_name: &str,
        array: &ArrayRef,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_bool_array(
        &self,
        array: &BooleanArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_int16_array(
        &self,
        array: &Int16Array,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_int32_array(
        &self,
        array: &Int32Array,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_int64_array(
        &self,
        array: &Int64Array,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_int256_array(
        &self,
        array: &Decimal256Array,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_decimal128_array(
        &self,
        array: &Decimal128Array,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_float32_array(
        &self,
        array: &Float32Array,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_float64_array(
        &self,
        array: &Float64Array,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_date32_array(
        &self,
        array: &Date32Array,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_time64us_array(
        &self,
        array: &Time64MicrosecondArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_timestampsecond_array(
        &self,
        array: &TimestampSecondArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_timestampsecond_some_array(
        &self,
        array: &TimestampSecondArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_timestampms_array(
        &self,
        array: &TimestampMillisecondArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_timestampms_some_array(
        &self,
        array: &TimestampMillisecondArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_timestampus_array(
        &self,
        array: &TimestampMicrosecondArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_timestampus_some_array(
        &self,
        array: &TimestampMicrosecondArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_timestampns_array(
        &self,
        array: &TimestampNanosecondArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_timestampns_some_array(
        &self,
        array: &TimestampNanosecondArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_interval_array(
        &self,
        array: &IntervalMonthDayNanoArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_utf8_array(
        &self,
        array: &StringArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_binary_array(
        &self,
        array: &BinaryArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_large_utf8_array(
        &self,
        array: &LargeStringArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_large_binary_array(
        &self,
        array: &LargeBinaryArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_list_array(
        &self,
        array: &ListArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_struct_array(
        &self,
        array: &StructArray,
    ) -> Result<ArrayImpl, ArrayError> { ... }
    fn from_map_array(&self, array: &MapArray) -> Result<ArrayImpl, ArrayError> { ... }
}

Defines how to convert Arrow arrays to RisingWave arrays.

Provided Methods

fn from_record_batch( &self, batch: &RecordBatch, ) -> Result<DataChunk, ArrayError>

Converts Arrow RecordBatch to RisingWave DataChunk.

fn from_fields(&self, fields: &Fields) -> Result<StructType, ArrayError>

Converts Arrow Fields to RisingWave StructType.

fn from_field(&self, field: &Field) -> Result<DataType, ArrayError>

Converts Arrow Field to RisingWave DataType.

fn from_large_utf8(&self) -> Result<DataType, ArrayError>

Converts Arrow LargeUtf8 type to RisingWave data type.

fn from_large_binary(&self) -> Result<DataType, ArrayError>

Converts Arrow LargeBinary type to RisingWave data type.

fn from_extension_type( &self, type_name: &str, physical_type: &DataType, ) -> Result<DataType, ArrayError>

Converts Arrow extension type to RisingWave DataType.

fn from_array( &self, field: &Field, array: &ArrayRef, ) -> Result<ArrayImpl, ArrayError>

Converts Arrow Array to RisingWave ArrayImpl.

fn from_extension_array( &self, type_name: &str, array: &ArrayRef, ) -> Result<ArrayImpl, ArrayError>

Converts Arrow extension array to RisingWave ArrayImpl.

fn from_bool_array(&self, array: &BooleanArray) -> Result<ArrayImpl, ArrayError>

fn from_int16_array(&self, array: &Int16Array) -> Result<ArrayImpl, ArrayError>

fn from_int32_array(&self, array: &Int32Array) -> Result<ArrayImpl, ArrayError>

fn from_int64_array(&self, array: &Int64Array) -> Result<ArrayImpl, ArrayError>

fn from_int256_array( &self, array: &Decimal256Array, ) -> Result<ArrayImpl, ArrayError>

fn from_decimal128_array( &self, array: &Decimal128Array, ) -> Result<ArrayImpl, ArrayError>

fn from_float32_array( &self, array: &Float32Array, ) -> Result<ArrayImpl, ArrayError>

fn from_float64_array( &self, array: &Float64Array, ) -> Result<ArrayImpl, ArrayError>

fn from_date32_array( &self, array: &Date32Array, ) -> Result<ArrayImpl, ArrayError>

fn from_time64us_array( &self, array: &Time64MicrosecondArray, ) -> Result<ArrayImpl, ArrayError>

fn from_timestampsecond_array( &self, array: &TimestampSecondArray, ) -> Result<ArrayImpl, ArrayError>

fn from_timestampsecond_some_array( &self, array: &TimestampSecondArray, ) -> Result<ArrayImpl, ArrayError>

fn from_timestampms_array( &self, array: &TimestampMillisecondArray, ) -> Result<ArrayImpl, ArrayError>

fn from_timestampms_some_array( &self, array: &TimestampMillisecondArray, ) -> Result<ArrayImpl, ArrayError>

fn from_timestampus_array( &self, array: &TimestampMicrosecondArray, ) -> Result<ArrayImpl, ArrayError>

fn from_timestampus_some_array( &self, array: &TimestampMicrosecondArray, ) -> Result<ArrayImpl, ArrayError>

fn from_timestampns_array( &self, array: &TimestampNanosecondArray, ) -> Result<ArrayImpl, ArrayError>

fn from_timestampns_some_array( &self, array: &TimestampNanosecondArray, ) -> Result<ArrayImpl, ArrayError>

fn from_interval_array( &self, array: &IntervalMonthDayNanoArray, ) -> Result<ArrayImpl, ArrayError>

fn from_utf8_array(&self, array: &StringArray) -> Result<ArrayImpl, ArrayError>

fn from_binary_array( &self, array: &BinaryArray, ) -> Result<ArrayImpl, ArrayError>

fn from_large_utf8_array( &self, array: &LargeStringArray, ) -> Result<ArrayImpl, ArrayError>

fn from_large_binary_array( &self, array: &LargeBinaryArray, ) -> Result<ArrayImpl, ArrayError>

fn from_list_array(&self, array: &ListArray) -> Result<ArrayImpl, ArrayError>

fn from_struct_array( &self, array: &StructArray, ) -> Result<ArrayImpl, ArrayError>

fn from_map_array(&self, array: &MapArray) -> Result<ArrayImpl, ArrayError>

Implementors

impl FromArrow for IcebergArrowConvert

impl FromArrow for UdfArrowConvert