Struct ArrowReaderBuilder 

pub struct ArrowReaderBuilder<R> { /* private fields */ }

Implementations

impl<R> ArrowReaderBuilder<R>

pub fn file_metadata(&self) -> &FileMetadata

pub fn with_batch_size(self, batch_size: usize) -> Self

pub fn with_projection(self, projection: ProjectionMask) -> Self

pub fn with_schema(self, schema: SchemaRef) -> Self

pub fn with_file_byte_range(self, range: Range<usize>) -> Self

Specifies a range of file bytes that will read the strips offset within this range

pub fn with_row_selection(self, row_selection: RowSelection) -> Self

Set a RowSelection to filter rows

The RowSelection specifies which rows should be decoded from the ORC file. This can be used to skip rows that don’t match predicates, reducing I/O and improving query performance.

Example

let file = File::open("data.orc").unwrap();
let selection = vec![
    RowSelector::skip(100),
    RowSelector::select(50),
].into();
let reader = ArrowReaderBuilder::try_new(file)
    .unwrap()
    .with_row_selection(selection)
    .build();

pub fn schema(&self) -> SchemaRef

Returns the currently computed schema

Unless with_schema was called, this is computed dynamically based on the current projection and the underlying file format.

impl<R: ChunkReader> ArrowReaderBuilder<R>

pub fn try_new(reader: R) -> Result<Self>

pub fn build(self) -> ArrowReader<R>

impl<R: AsyncChunkReader + 'static> ArrowReaderBuilder<R>

pub async fn try_new_async(reader: R) -> Result<Self>

pub fn build_async(self) -> ArrowStreamReader<R>