Struct deltalake::kernel::models::Add

source ·
pub struct Add {
    pub path: String,
    pub partition_values: HashMap<String, Option<String>>,
    pub size: i64,
    pub modification_time: i64,
    pub data_change: bool,
    pub stats: Option<String>,
    pub tags: Option<HashMap<String, Option<String>>>,
    pub deletion_vector: Option<DeletionVectorDescriptor>,
    pub base_row_id: Option<i64>,
    pub default_row_commit_version: Option<i64>,
    pub clustering_provider: Option<String>,
    pub stats_parsed: Option<Row>,
}
Expand description

Defines an add action

Fields§

§path: String

A relative path to a data file from the root of the table or an absolute path to a file that should be added to the table. The path is a URI as specified by RFC 2396 URI Generic Syntax, which needs to be decoded to get the data file path.

§partition_values: HashMap<String, Option<String>>

A map from partition column to value for this logical file.

§size: i64

The size of this data file in bytes

§modification_time: i64

The time this logical file was created, as milliseconds since the epoch.

§data_change: bool

When false the logical file must already be present in the table or the records in the added file must be contained in one or more remove actions in the same version.

§stats: Option<String>

Contains statistics (e.g., count, min/max values for columns) about the data in this logical file.

§tags: Option<HashMap<String, Option<String>>>

Map containing metadata about this logical file.

§deletion_vector: Option<DeletionVectorDescriptor>

Information about deletion vector (DV) associated with this add action

§base_row_id: Option<i64>

Default generated Row ID of the first row in the file. The default generated Row IDs of the other rows in the file can be reconstructed by adding the physical index of the row within the file to the base Row ID

§default_row_commit_version: Option<i64>

First commit version in which an add action with the same path was committed to the table.

§clustering_provider: Option<String>

The name of the clustering implementation

§stats_parsed: Option<Row>

Contains statistics (e.g., count, min/max values for columns) about the data in this file in raw parquet format. This field needs to be written when statistics are available and the table property: delta.checkpoint.writeStatsAsStruct is set to true.

This field is only available in add action records read from checkpoints

Implementations§

source§

impl Add

source

pub fn get_stats_parsed(&self) -> Result<Option<Stats>, ProtocolError>

Returns the composite HashMap representation of stats contained in the action if present. Since stats are defined as optional in the protocol, this may be None.

Trait Implementations§

source§

impl Clone for Add

source§

fn clone(&self) -> Add

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 Add

source§

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

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

impl Default for Add

source§

fn default() -> Add

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

impl<'de> Deserialize<'de> for Add

source§

fn deserialize<__D>( __deserializer: __D ) -> Result<Add, <__D as Deserializer<'de>>::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
source§

impl FileAction for Add

source§

fn partition_values(&self) -> &HashMap<String, Option<String>>

Adds partition values
source§

fn path(&self) -> String

Physical Path to the data
source§

fn size(&self) -> usize

Byte size of the physical file
source§

impl From<Add> for Action

source§

fn from(a: Add) -> Action

Converts to this type from the input type.
source§

impl Hash for Add

source§

fn hash<H>(&self, state: &mut H)
where H: Hasher,

Feeds this value into the given Hasher. Read more
1.3.0 · source§

fn hash_slice<H>(data: &[Self], state: &mut H)
where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher. Read more
source§

impl PartialEq for Add

source§

fn eq(&self, other: &Add) -> bool

This method tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
source§

impl Serialize for Add

source§

fn serialize<__S>( &self, __serializer: __S ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>
where __S: Serializer,

Serialize this value into the given Serde serializer. Read more
source§

impl TryFrom<&Add> for ObjectMeta

§

type Error = DeltaTableError

The type returned in the event of a conversion error.
source§

fn try_from(value: &Add) -> Result<ObjectMeta, DeltaTableError>

Performs the conversion.
source§

impl TryFrom<Add> for ObjectMeta

§

type Error = DeltaTableError

The type returned in the event of a conversion error.
source§

fn try_from(value: Add) -> Result<ObjectMeta, DeltaTableError>

Performs the conversion.
source§

impl Eq for Add

Auto Trait Implementations§

§

impl Freeze for Add

§

impl RefUnwindSafe for Add

§

impl Send for Add

§

impl Sync for Add

§

impl Unpin for Add

§

impl UnwindSafe for Add

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<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

source§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

source§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
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> 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

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> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

source§

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