Struct deltalake::arrow::ipc::reader::FileReaderBuilder

source ·
pub struct FileReaderBuilder { /* private fields */ }
Expand description

Build an Arrow FileReader with custom options.

Implementations§

source§

impl FileReaderBuilder

source

pub fn new() -> FileReaderBuilder

Options for creating a new FileReader.

To convert a builder into a reader, call FileReaderBuilder::build.

source

pub fn with_projection(self, projection: Vec<usize>) -> FileReaderBuilder

Optional projection for which columns to load (zero-based column indices).

Flatbuffers option for parsing the footer. Controls the max number of fields and metadata key-value pairs that can be parsed from the schema of the footer.

By default this is set to 1_000_000 which roughly translates to a schema with no metadata key-value pairs but 499,999 fields.

This default limit is enforced to protect against malicious files with a massive amount of flatbuffer tables which could cause a denial of service attack.

If you need to ingest a trusted file with a massive number of fields and/or metadata key-value pairs and are facing the error "Unable to get root as footer: TooManyTables" then increase this parameter as necessary.

Flatbuffers option for parsing the footer. Controls the max depth for schemas with nested fields parsed from the footer.

By default this is set to 64 which roughly translates to a schema with a field nested 60 levels down through other struct fields.

This default limit is enforced to protect against malicious files with a extremely deep flatbuffer structure which could cause a denial of service attack.

If you need to ingest a trusted file with a deeply nested field and are facing the error "Unable to get root as footer: DepthLimitReached" then increase this parameter as necessary.

source

pub fn build<R>(self, reader: R) -> Result<FileReader<R>, ArrowError>
where R: Read + Seek,

Build FileReader with given reader.

Trait Implementations§

source§

impl Debug for FileReaderBuilder

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter. Read more
source§

impl Default for FileReaderBuilder

source§

fn default() -> FileReaderBuilder

Returns the “default value” for a type. Read more

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> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
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> IntoEither for T

source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

source§

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

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

§

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>,

§

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.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

source§

impl<T> Ungil for T
where T: Send,