Skip to main content

ArrowArrayStream

Struct ArrowArrayStream 

Source
#[repr(C)]
pub struct ArrowArrayStream { pub get_schema: Option<unsafe extern "C" fn(*mut ArrowArrayStream, *mut ArrowSchema) -> i32>, pub get_next: Option<unsafe extern "C" fn(*mut ArrowArrayStream, *mut ArrowArray) -> i32>, pub get_last_error: Option<unsafe extern "C" fn(*mut ArrowArrayStream) -> *const i8>, pub release: Option<unsafe extern "C" fn(*mut ArrowArrayStream)>, pub private_data: *mut c_void, }
Expand description

ArrowArrayStream as per the Arrow C Stream Interface spec.

Provides a streaming interface for consuming a sequence of ArrowArrays with a shared schema. Used by the PyCapsule protocol for chunked data exchange between different runtimes and languages.

See: https://arrow.apache.org/docs/format/CStreamInterface.html

Fields§

§get_schema: Option<unsafe extern "C" fn(*mut ArrowArrayStream, *mut ArrowSchema) -> i32>§get_next: Option<unsafe extern "C" fn(*mut ArrowArrayStream, *mut ArrowArray) -> i32>§get_last_error: Option<unsafe extern "C" fn(*mut ArrowArrayStream) -> *const i8>§release: Option<unsafe extern "C" fn(*mut ArrowArrayStream)>§private_data: *mut c_void

Implementations§

Source§

impl ArrowArrayStream

Source

pub fn empty() -> ArrowArrayStream

Creates an empty ArrowArrayStream for receiving FFI data.

Trait Implementations§

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.