Skip to main content

CommitMetadata

Struct CommitMetadata 

Source
pub struct CommitMetadata { /* private fields */ }
Expand description

CommitMetadata bundles the metadata about a commit operation. This includes the commit path, version, and protocol/metadata state of the table being committed to. Catalog committers can use the protocol and metadata getters to validate or inspect the commit.

Note that this struct cannot be constructed. It is handed to the Committer (in the commit method) by the kernel when a transaction is being committed.

See the module-level documentation for more details.

Implementations§

Source§

impl CommitMetadata

Source

pub fn published_commit_path(&self) -> DeltaResult<Url>

The commit path is the absolute path (e.g. s3://bucket/table/_delta_log/{version}.json) to the published delta file for this commit.

Source

pub fn staged_commit_path(&self) -> DeltaResult<Url>

The staged commit path is the absolute path (e.g. s3://bucket/table/_delta_log/{version}.{uuid}.json) to the staged commit file.

Source

pub fn version(&self) -> Version

The version to which the transaction is being committed.

Source

pub fn commit_type(&self) -> CommitType

The type of commit operation being performed.

Source

pub fn in_commit_timestamp(&self) -> i64

The in-commit timestamp for the commit. Note that this may differ from the actual commit file modification time.

Source

pub fn max_published_version(&self) -> Option<Version>

The maximum published version of the table.

Source

pub fn table_root(&self) -> &Url

The root URL of the table being committed to.

Source

pub fn has_writer_feature(&self, feature_name: &str) -> bool

Check if the effective protocol has a specific writer feature by name.

Source

pub fn has_reader_feature(&self, feature_name: &str) -> bool

Check if the effective protocol has a specific reader feature by name.

Source

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

Get the raw metadata configuration for the effective metadata. Returns None if no metadata is set.

Source

pub fn has_protocol_change(&self) -> bool

Returns true if this commit changes the table’s protocol.

Source

pub fn has_metadata_change(&self) -> bool

Returns true if this commit changes the table’s metadata.

Source

pub fn has_domain_metadata_change(&self, domain: &str) -> bool

Returns true if this commit includes a domain metadata change for the given domain name.

Source

pub fn new_unchecked(table_root: Url, version: Version) -> DeltaResult<Self>

Available on crate features test-utils only.

Creates a new CommitMetadata for the given table_root and version. Test-only.

Uses a default modern protocol (empty features) and empty metadata.

Source

pub fn new_unchecked_with( table_root: Url, version: Version, reader_features: Vec<&str>, writer_features: Vec<&str>, configuration: HashMap<String, String>, ) -> DeltaResult<Self>

Available on crate features test-utils only.

Creates a new CommitMetadata with specific features and configuration. Test-only.

Source

pub fn with_protocol_change(self) -> Self

Available on crate features test-utils only.

Marks this CommitMetadata as having a protocol change. Test-only.

that changes the protocol.

Source

pub fn with_metadata_change(self) -> Self

Available on crate features test-utils only.

Marks this CommitMetadata as having a metadata change. Test-only.

Copies the existing metadata into the new_metadata field to simulate an ALTER TABLE that changes the metadata.

Source

pub fn with_domain_change(self, domain: &str) -> Self

Available on crate features test-utils only.

Adds a domain metadata change for the given domain name. Test-only.

Creates a synthetic domain metadata entry to simulate a domain metadata change (e.g. clustering column change via ALTER TABLE CLUSTER BY).

Trait Implementations§

Source§

impl Debug for CommitMetadata

Source§

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

Formats the value using the given formatter. 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> AsAny for T
where T: Any + Send + Sync,

Source§

fn any_ref(&self) -> &(dyn Any + Send + Sync + 'static)

Obtains a dyn Any reference to the object: Read more
Source§

fn as_any(self: Arc<T>) -> Arc<dyn Any + Send + Sync>

Obtains an Arc<dyn Any> reference to the object: Read more
Source§

fn into_any(self: Box<T>) -> Box<dyn Any + Send + Sync>

Converts the object to Box<dyn Any>: Read more
Source§

fn type_name(&self) -> &'static str

Convenient wrapper for std::any::type_name, since Any does not provide it and Any::type_id is useless as a debugging aid (its Debug is just a mess of hex digits).
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<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

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

Source§

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

Source§

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<KernelType, ArrowType> TryIntoArrow<ArrowType> for KernelType
where ArrowType: TryFromKernel<KernelType>,

Source§

fn try_into_arrow(self) -> Result<ArrowType, ArrowError>

Available on (crate features default-engine-native-tls or default-engine-rustls or arrow-conversion) and crate feature arrow-conversion only.
Source§

impl<KernelType, ArrowType> TryIntoKernel<KernelType> for ArrowType
where KernelType: TryFromArrow<ArrowType>,

Source§

fn try_into_kernel(self) -> Result<KernelType, ArrowError>

Available on (crate features default-engine-native-tls or default-engine-rustls or arrow-conversion) and crate feature arrow-conversion only.
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,