Struct GeozeroRecordBatchReader

pub struct GeozeroRecordBatchReader(/* private fields */);

Available on crate feature geozero only.

A newtype wrapper around an arrow_array::RecordBatchReader so that we can implement the geozero::GeozeroDatasource trait on it.

This allows for exporting Arrow data to a geozero-based consumer even when not all of the Arrow data is present in memory at once.

Implementations

impl GeozeroRecordBatchReader

pub fn new(reader: Box<dyn RecordBatchReader>) -> Self

Create a new GeozeroRecordBatchReader from a RecordBatchReader.

pub fn into_inner(self) -> Box<dyn RecordBatchReader>

Access the underlying RecordBatchReader.

Trait Implementations

impl AsMut<Box<dyn RecordBatchReader<Item = Result<RecordBatch, ArrowError>>>> for GeozeroRecordBatchReader

fn as_mut(&mut self) -> &mut Box<dyn RecordBatchReader>

Converts this type into a mutable reference of the (usually inferred) input type.

impl AsRef<Box<dyn RecordBatchReader<Item = Result<RecordBatch, ArrowError>>>> for GeozeroRecordBatchReader

fn as_ref(&self) -> &Box<dyn RecordBatchReader>

Converts this type into a shared reference of the (usually inferred) input type.

impl From<Box<dyn RecordBatchReader<Item = Result<RecordBatch, ArrowError>>>> for GeozeroRecordBatchReader

fn from(value: Box<dyn RecordBatchReader>) -> Self

Converts to this type from the input type.

impl From<Box<dyn RecordBatchReader<Item = Result<RecordBatch, ArrowError>> + Send>> for GeozeroRecordBatchReader

fn from(value: Box<dyn RecordBatchReader + Send>) -> Self

Converts to this type from the input type.

impl GeozeroDatasource for GeozeroRecordBatchReader

fn process<P: FeatureProcessor>( &mut self, processor: &mut P, ) -> Result<(), GeozeroError>

Consume and process all selected features.

fn process_geom<P>(&mut self, processor: &mut P) -> Result<(), GeozeroError>

where P: GeomProcessor,

Consume and process geometries of all selected features.