Struct datafusion::datasource::listing::PartitionedFile

source ·
pub struct PartitionedFile {
    pub object_meta: ObjectMeta,
    pub partition_values: Vec<ScalarValue>,
    pub range: Option<FileRange>,
    pub statistics: Option<Statistics>,
    pub extensions: Option<Arc<dyn Any + Send + Sync>>,
}
Expand description

A single file or part of a file that should be read, along with its schema, statistics and partition column values that need to be appended to each row.

Fields§

§object_meta: ObjectMeta

Path for the file (e.g. URL, filesystem path, etc)

§partition_values: Vec<ScalarValue>

Values of partition columns to be appended to each row.

These MUST have the same count, order, and type than the table_partition_cols.

You may use wrap_partition_value_in_dict to wrap them if you have used wrap_partition_type_in_dict to wrap the column type.

§range: Option<FileRange>

An optional file range for a more fine-grained parallel execution

§statistics: Option<Statistics>

Optional statistics that describe the data in this file if known.

DataFusion relies on these statistics for planning (in particular to sort file groups), so if they are incorrect, incorrect answers may result.

§extensions: Option<Arc<dyn Any + Send + Sync>>

An optional field for user defined per object metadata

Implementations§

source§

impl PartitionedFile

source

pub fn new(path: impl Into<String>, size: u64) -> Self

Create a simple file without metadata or partition

source

pub fn new_with_range(path: String, size: u64, start: i64, end: i64) -> Self

Create a file range without metadata or partition

source

pub fn from_path(path: String) -> Result<Self>

Return a file reference from the given path

source

pub fn path(&self) -> &Path

Return the path of this partitioned file

source

pub fn with_range(self, start: i64, end: i64) -> Self

Update the file to only scan the specified range (in bytes)

Trait Implementations§

source§

impl Clone for PartitionedFile

source§

fn clone(&self) -> PartitionedFile

Returns a copy of the value. Read more
1.0.0 · source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
source§

impl Debug for PartitionedFile

source§

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

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

impl From<ObjectMeta> for PartitionedFile

source§

fn from(object_meta: ObjectMeta) -> Self

Converts to this type from the input type.

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, 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<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
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