pub struct PyRecordBatchReader(/* private fields */);
Expand description
A Python-facing Arrow record batch reader.
This is a wrapper around a RecordBatchReader.
Implementations§
Source§impl PyRecordBatchReader
impl PyRecordBatchReader
Sourcepub fn new(reader: Box<dyn RecordBatchReader + Send>) -> Self
pub fn new(reader: Box<dyn RecordBatchReader + Send>) -> Self
Construct a new PyRecordBatchReader from an existing RecordBatchReader.
Sourcepub fn from_arrow_pycapsule(capsule: &Bound<'_, PyCapsule>) -> PyResult<Self>
pub fn from_arrow_pycapsule(capsule: &Bound<'_, PyCapsule>) -> PyResult<Self>
Construct from a raw Arrow C Stream capsule
Sourcepub fn into_reader(self) -> PyResult<Box<dyn RecordBatchReader + Send>>
pub fn into_reader(self) -> PyResult<Box<dyn RecordBatchReader + Send>>
Consume this reader and convert into a RecordBatchReader.
The reader can only be consumed once. Calling into_reader
Sourcepub fn into_table(self) -> PyArrowResult<PyTable>
pub fn into_table(self) -> PyArrowResult<PyTable>
Consume this reader and create a PyTable object
Sourcepub fn schema_ref(&self) -> PyResult<SchemaRef>
pub fn schema_ref(&self) -> PyResult<SchemaRef>
Access the SchemaRef of this RecordBatchReader.
If the stream has already been consumed, this method will error.
Sourcepub fn to_arro3<'py>(&'py self, py: Python<'py>) -> PyResult<Bound<'py, PyAny>>
pub fn to_arro3<'py>(&'py self, py: Python<'py>) -> PyResult<Bound<'py, PyAny>>
Export this to a Python arro3.core.RecordBatchReader
.
Sourcepub fn into_arro3(self, py: Python<'_>) -> PyResult<Bound<'_, PyAny>>
pub fn into_arro3(self, py: Python<'_>) -> PyResult<Bound<'_, PyAny>>
Export this to a Python arro3.core.RecordBatchReader
.
Trait Implementations§
Source§impl Display for PyRecordBatchReader
impl Display for PyRecordBatchReader
Source§impl From<Box<dyn RecordBatchReader<Item = Result<RecordBatch, ArrowError>> + Send>> for PyRecordBatchReader
impl From<Box<dyn RecordBatchReader<Item = Result<RecordBatch, ArrowError>> + Send>> for PyRecordBatchReader
Source§impl From<PyRecordBatchReader> for Arro3RecordBatchReader
impl From<PyRecordBatchReader> for Arro3RecordBatchReader
Source§fn from(value: PyRecordBatchReader) -> Self
fn from(value: PyRecordBatchReader) -> Self
Converts to this type from the input type.
Source§impl<'a> FromPyObject<'a> for PyRecordBatchReader
impl<'a> FromPyObject<'a> for PyRecordBatchReader
Source§impl<'py> IntoPyObject<'py> for PyRecordBatchReader
impl<'py> IntoPyObject<'py> for PyRecordBatchReader
Source§type Target = PyRecordBatchReader
type Target = PyRecordBatchReader
The Python output type
Source§type Output = Bound<'py, <PyRecordBatchReader as IntoPyObject<'py>>::Target>
type Output = Bound<'py, <PyRecordBatchReader as IntoPyObject<'py>>::Target>
The smart pointer type to use. Read more
Source§fn into_pyobject(
self,
py: Python<'py>,
) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>
fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>
Performs the conversion.
Source§impl PyClass for PyRecordBatchReader
impl PyClass for PyRecordBatchReader
Source§impl PyClassBaseType for PyRecordBatchReader
impl PyClassBaseType for PyRecordBatchReader
type LayoutAsBase = PyClassObject<PyRecordBatchReader>
type BaseNativeType = <PyRecordBatchReader as PyClassImpl>::BaseNativeType
type Initializer = PyClassInitializer<PyRecordBatchReader>
type PyClassMutability = <PyRecordBatchReader as PyClassImpl>::PyClassMutability
Source§impl PyClassImpl for PyRecordBatchReader
impl PyClassImpl for PyRecordBatchReader
Source§const IS_BASETYPE: bool = true
const IS_BASETYPE: bool = true
#[pyclass(subclass)]
Source§const IS_SUBCLASS: bool = false
const IS_SUBCLASS: bool = false
#[pyclass(extends=…)]
Source§const IS_MAPPING: bool = false
const IS_MAPPING: bool = false
#[pyclass(mapping)]
Source§const IS_SEQUENCE: bool = false
const IS_SEQUENCE: bool = false
#[pyclass(sequence)]
Source§const IS_IMMUTABLE_TYPE: bool = false
const IS_IMMUTABLE_TYPE: bool = false
#[pyclass(immutable_type)]
Source§const RAW_DOC: &'static CStr = /// A Python-facing Arrow record batch reader.
///
/// This is a wrapper around a [RecordBatchReader].
const RAW_DOC: &'static CStr = /// A Python-facing Arrow record batch reader. /// /// This is a wrapper around a [RecordBatchReader].
Docstring for the class provided on the struct or enum. Read more
Source§const DOC: &'static CStr
const DOC: &'static CStr
Fully rendered class doc, including the
text_signature
if a constructor is defined. Read moreSource§type ThreadChecker = SendablePyClass<PyRecordBatchReader>
type ThreadChecker = SendablePyClass<PyRecordBatchReader>
This handles following two situations: Read more
Source§type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::ImmutableChild
type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::ImmutableChild
Immutable or mutable
Source§type BaseNativeType = PyAny
type BaseNativeType = PyAny
The closest native ancestor. This is
PyAny
by default, and when you declare
#[pyclass(extends=PyDict)]
, it’s PyDict
.fn items_iter() -> PyClassItemsIter
fn lazy_type_object() -> &'static LazyTypeObject<Self>
fn dict_offset() -> Option<isize>
fn weaklist_offset() -> Option<isize>
Source§impl<'a, 'holder, 'py> PyFunctionArgument<'a, 'holder, 'py, false> for &'holder PyRecordBatchReader
impl<'a, 'holder, 'py> PyFunctionArgument<'a, 'holder, 'py, false> for &'holder PyRecordBatchReader
Source§impl PyMethods<PyRecordBatchReader> for PyClassImplCollector<PyRecordBatchReader>
impl PyMethods<PyRecordBatchReader> for PyClassImplCollector<PyRecordBatchReader>
fn py_methods(self) -> &'static PyClassItems
Source§impl PyTypeInfo for PyRecordBatchReader
impl PyTypeInfo for PyRecordBatchReader
Source§fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject
fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject
Returns the PyTypeObject instance for this type.
Source§fn type_object(py: Python<'_>) -> Bound<'_, PyType>
fn type_object(py: Python<'_>) -> Bound<'_, PyType>
Returns the safe abstraction over the type object.
impl DerefToPyAny for PyRecordBatchReader
Auto Trait Implementations§
impl !Freeze for PyRecordBatchReader
impl RefUnwindSafe for PyRecordBatchReader
impl Send for PyRecordBatchReader
impl Sync for PyRecordBatchReader
impl Unpin for PyRecordBatchReader
impl UnwindSafe for PyRecordBatchReader
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<'py, T> FromPyObjectBound<'_, 'py> for Twhere
T: FromPyObject<'py>,
impl<'py, T> FromPyObjectBound<'_, 'py> for Twhere
T: FromPyObject<'py>,
Source§impl<'py, T> IntoPyObjectExt<'py> for Twhere
T: IntoPyObject<'py>,
impl<'py, T> IntoPyObjectExt<'py> for Twhere
T: IntoPyObject<'py>,
Source§fn into_bound_py_any(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>
fn into_bound_py_any(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>
Converts
self
into an owned Python object, dropping type information.