#[pyo3(signature = (requested_schema=None))]

fn __arrow_c_array__<'py>(

&'py self,

py: Python<'py>,

requested_schema: Option<Bound<'py, PyCapsule>>,

) -> PyDataFusionResult<(Bound<'py, PyCapsule>, Bound<'py, PyCapsule>)> {

let field = if let Some(schema_capsule) = requested_schema {

validate_pycapsule(&schema_capsule, "arrow_schema")?;

let data: NonNull<FFI_ArrowSchema> = schema_capsule

.pointer_checked(Some(c_str!("arrow_schema")))?

.cast();

let schema_ptr = unsafe { data.as_ref() };

let desired_field = Field::try_from(schema_ptr)?;

Arc::new(desired_field)

} else {

Arc::clone(&self.field)

};

let ffi_schema = FFI_ArrowSchema::try_from(&field)?;

let schema_capsule = PyCapsule::new(py, ffi_schema, Some(cr"arrow_schema".into()))?;

let ffi_array = FFI_ArrowArray::new(&self.array.to_data());

let array_capsule = PyCapsule::new(py, ffi_array, Some(cr"arrow_array".into()))?;

Ok((schema_capsule, array_capsule))

}

fn to_pyarrow<'py>(&self, py: Python<'py>) -> PyResult<Bound<'py, PyAny>> {

let module = py.import("pyarrow")?;

let method = module.getattr("array")?;

let array = method.call((self.clone(),), None)?;

Ok(array)

}

pub fn new(array: ArrayRef, field: FieldRef) -> Self {

Self { array, field }

}