Struct TableProperties

Source
pub struct TableProperties {
    pub commit_num_retries: usize,
    pub commit_min_retry_wait_ms: u64,
    pub commit_max_retry_wait_ms: u64,
    pub commit_total_retry_timeout_ms: u64,
    pub write_format_default: String,
    pub write_target_file_size_bytes: usize,
}
Expand description

TableProperties that contains the properties of a table.

Fields§

§commit_num_retries: usize

The number of times to retry a commit.

§commit_min_retry_wait_ms: u64

The minimum wait time between retries.

§commit_max_retry_wait_ms: u64

The maximum wait time between retries.

§commit_total_retry_timeout_ms: u64

The total timeout for commit retries.

§write_format_default: String

The default format for files.

§write_target_file_size_bytes: usize

The target file size for files.

Implementations§

Source§

impl TableProperties

Source

pub const PROPERTY_FORMAT_VERSION: &str = "format-version"

Reserved table property for table format version.

Iceberg will default a new table’s format version to the latest stable and recommended version. This reserved property keyword allows users to override the Iceberg format version of the table metadata.

If this table property exists when creating a table, the table will use the specified format version. If a table updates this property, it will try to upgrade to the specified format version.

Source

pub const PROPERTY_UUID: &str = "uuid"

Reserved table property for table UUID.

Source

pub const PROPERTY_SNAPSHOT_COUNT: &str = "snapshot-count"

Reserved table property for the total number of snapshots.

Source

pub const PROPERTY_CURRENT_SNAPSHOT_SUMMARY: &str = "current-snapshot-summary"

Reserved table property for current snapshot summary.

Source

pub const PROPERTY_CURRENT_SNAPSHOT_ID: &str = "current-snapshot-id"

Reserved table property for current snapshot id.

Source

pub const PROPERTY_CURRENT_SNAPSHOT_TIMESTAMP: &str = "current-snapshot-timestamp-ms"

Reserved table property for current snapshot timestamp.

Source

pub const PROPERTY_CURRENT_SCHEMA: &str = "current-schema"

Reserved table property for the JSON representation of current schema.

Source

pub const PROPERTY_DEFAULT_PARTITION_SPEC: &str = "default-partition-spec"

Reserved table property for the JSON representation of current(default) partition spec.

Source

pub const PROPERTY_DEFAULT_SORT_ORDER: &str = "default-sort-order"

Reserved table property for the JSON representation of current(default) sort order.

Source

pub const PROPERTY_METADATA_PREVIOUS_VERSIONS_MAX: &str = "write.metadata.previous-versions-max"

Property key for max number of previous versions to keep.

Source

pub const PROPERTY_METADATA_PREVIOUS_VERSIONS_MAX_DEFAULT: usize = 100usize

Default value for max number of previous versions to keep.

Source

pub const PROPERTY_WRITE_PARTITION_SUMMARY_LIMIT: &str = "write.summary.partition-limit"

Property key for max number of partitions to keep summary stats for.

Source

pub const PROPERTY_WRITE_PARTITION_SUMMARY_LIMIT_DEFAULT: u64 = 0u64

Default value for the max number of partitions to keep summary stats for.

Source

pub const RESERVED_PROPERTIES: [&str; 9]

Reserved Iceberg table properties list.

Reserved table properties are only used to control behaviors when creating or updating a table. The value of these properties are not persisted as a part of the table metadata.

Source

pub const PROPERTY_COMMIT_NUM_RETRIES: &str = "commit.retry.num-retries"

Property key for number of commit retries.

Source

pub const PROPERTY_COMMIT_NUM_RETRIES_DEFAULT: usize = 4usize

Default value for number of commit retries.

Source

pub const PROPERTY_COMMIT_MIN_RETRY_WAIT_MS: &str = "commit.retry.min-wait-ms"

Property key for minimum wait time (ms) between retries.

Source

pub const PROPERTY_COMMIT_MIN_RETRY_WAIT_MS_DEFAULT: u64 = 100u64

Default value for minimum wait time (ms) between retries.

Source

pub const PROPERTY_COMMIT_MAX_RETRY_WAIT_MS: &str = "commit.retry.max-wait-ms"

Property key for maximum wait time (ms) between retries.

Source

pub const PROPERTY_COMMIT_MAX_RETRY_WAIT_MS_DEFAULT: u64 = 60_000u64

Default value for maximum wait time (ms) between retries.

Source

pub const PROPERTY_COMMIT_TOTAL_RETRY_TIME_MS: &str = "commit.retry.total-timeout-ms"

Property key for total maximum retry time (ms).

Source

pub const PROPERTY_COMMIT_TOTAL_RETRY_TIME_MS_DEFAULT: u64 = 1_800_000u64

Default value for total maximum retry time (ms).

Source

pub const PROPERTY_DEFAULT_FILE_FORMAT: &str = "write.format.default"

Default file format for data files

Source

pub const PROPERTY_DELETE_DEFAULT_FILE_FORMAT: &str = "write.delete.format.default"

Default file format for delete files

Source

pub const PROPERTY_DEFAULT_FILE_FORMAT_DEFAULT: &str = "parquet"

Default value for data file format

Source

pub const PROPERTY_WRITE_TARGET_FILE_SIZE_BYTES: &str = "write.target-file-size-bytes"

Target file size for newly written files.

Source

pub const PROPERTY_WRITE_TARGET_FILE_SIZE_BYTES_DEFAULT: usize = 536_870_912usize

Default target file size

Trait Implementations§

Source§

impl Debug for TableProperties

Source§

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

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

impl TryFrom<&HashMap<String, String>> for TableProperties

Source§

type Error = Error

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

fn try_from(props: &HashMap<String, String>) -> Result<Self, Self::Error>

Performs the conversion.

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
§

impl<T> AsAny for T
where T: Any,

§

fn as_any(&self) -> &(dyn Any + 'static)

§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

§

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

Gets the type name of self
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
§

impl<T> Downcast for T
where T: AsAny + ?Sized,

§

fn is<T>(&self) -> bool
where T: AsAny,

Returns true if the boxed type is the same as T. Read more
§

fn downcast_ref<T>(&self) -> Option<&T>
where T: AsAny,

Forward to the method defined on the type Any.
§

fn downcast_mut<T>(&mut self) -> Option<&mut T>
where T: AsAny,

Forward to the method defined on the type Any.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

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

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

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
§

impl<T> Pointable for T

§

const ALIGN: usize

The alignment of pointer.
§

type Init = T

The type for initializers.
§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
§

impl<T> PolicyExt for T
where T: ?Sized,

§

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
§

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

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

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

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
§

fn with_current_subscriber(self) -> WithDispatch<Self>

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

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

§

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