StructType

Struct StructType 

Source
pub struct StructType {
    pub type_name: String,
    pub fields: IndexMap<String, StructField>,
}
Expand description

The deltalake crate is currently just a meta-package shim for deltalake-core A struct is used to represent both the top-level schema of the table as well as struct columns that contain nested columns.

Fields§

§type_name: String§fields: IndexMap<String, StructField>

The type of element stored in this array

Implementations§

Source§

impl StructType

Source

pub fn new(fields: impl IntoIterator<Item = StructField>) -> StructType

Source

pub fn try_new<E>( fields: impl IntoIterator<Item = Result<StructField, E>>, ) -> Result<StructType, E>

Source

pub fn project_as_struct( &self, names: &[impl AsRef<str>], ) -> Result<StructType, Error>

Get a StructType containing StructFields of the given names. The order of fields in the returned schema will match the order passed to this function, which can be different from this order in this schema. Returns an Err if a specified field doesn’t exist.

Source

pub fn project( &self, names: &[impl AsRef<str>], ) -> Result<Arc<StructType>, Error>

Get a SchemaRef containing StructFields of the given names. The order of fields in the returned schema will match the order passed to this function, which can be different from this order in this schema. Returns an Err if a specified field doesn’t exist.

Source

pub fn field(&self, name: impl AsRef<str>) -> Option<&StructField>

Source

pub fn index_of(&self, name: impl AsRef<str>) -> Option<usize>

Source

pub fn fields(&self) -> impl ExactSizeIterator

Source

pub fn leaves<'s>( &self, own_name: impl Into<Option<&'s str>>, ) -> ColumnNamesAndTypes

Extracts the name and type of all leaf columns, in schema order. Caller should pass Some own_name if this schema is embedded in a larger struct (e.g. add.*) and None if the schema is a top-level result (e.g. *).

NOTE: This method only traverses through StructType fields; MapType and ArrayType fields are considered leaves even if they contain StructType entries/elements.

Source

pub fn make_physical( &self, column_mapping_mode: ColumnMappingMode, ) -> StructType

Applies physical name mappings to this field. If the column_mapping_mode is ColumnMappingMode::Id, then each StructField will have its parquet field id in the ColumnMetadataKey::ParquetFieldId metadata field.

NOTE: Caller affirms that the schema was already validated by crate::table_features::validate_schema_column_mapping, to ensure that annotations are always and only present when column mapping mode is enabled.

Trait Implementations§

Source§

impl Clone for StructType

Source§

fn clone(&self) -> StructType

Returns a duplicate 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 StructType

Source§

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

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

impl<'de> Deserialize<'de> for StructType

Source§

fn deserialize<D>( deserializer: D, ) -> Result<StructType, <D as Deserializer<'de>>::Error>
where D: Deserializer<'de>, StructType: Sized,

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

impl From<StructType> for DataType

Source§

fn from(struct_type: StructType) -> DataType

Converts to this type from the input type.
Source§

impl PartialEq for StructType

Source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
Source§

impl Serialize for StructType

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 StructTypeExt for StructType

Source§

fn get_generated_columns(&self) -> Result<Vec<GeneratedColumn>, Error>

Get all get_generated_columns in the schemas

Source§

fn get_invariants(&self) -> Result<Vec<Invariant>, Error>

Get all invariants in the schemas

Source§

impl TryFromArrow<&Schema> for StructType

Source§

impl TryFromArrow<Arc<Schema>> for StructType

Source§

impl TryFromKernel<&StructType> for Schema

Source§

impl Eq for StructType

Source§

impl StructuralPartialEq for StructType

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 + Sync + Send + 'static)

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

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

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

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

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> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DynEq for T
where T: Eq + Any,

Source§

fn dyn_eq(&self, other: &(dyn Any + 'static)) -> bool

Source§

impl<T> DynPartialEq for T
where T: PartialEq + AsAny,

Source§

fn dyn_eq(&self, other: &(dyn Any + 'static)) -> bool

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

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

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

Initializes a with the given initializer. Read more
Source§

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

Dereferences the given pointer. Read more
Source§

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

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. 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> ToOwned for T
where T: Clone,

Source§

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

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>

Source§

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

Source§

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

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> ErasedDestructor for T
where T: 'static,

Source§

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