Struct Protocol

pub struct Protocol {
    pub min_reader_version: i32,
    pub min_writer_version: i32,
    pub reader_features: Option<HashSet<ReaderFeatures>>,
    pub writer_features: Option<HashSet<WriterFeatures>>,
}

Defines a protocol action

Fields

min_reader_version: i32

The minimum version of the Delta read protocol that a client must implement in order to correctly read this table

min_writer_version: i32

The minimum version of the Delta write protocol that a client must implement in order to correctly write this table

reader_features: Option<HashSet<ReaderFeatures>>

A collection of features that a client must implement in order to correctly read this table (exist only when minReaderVersion is set to 3)

writer_features: Option<HashSet<WriterFeatures>>

A collection of features that a client must implement in order to correctly write this table (exist only when minWriterVersion is set to 7)

Implementations

impl Protocol

pub fn new(min_reader_version: i32, min_writer_version: i32) -> Self

Create a new protocol action

pub fn with_reader_features( self, reader_features: impl IntoIterator<Item = impl Into<ReaderFeatures>>, ) -> Self

set the reader features in the protocol action, automatically bumps min_reader_version

pub fn with_writer_features( self, writer_features: impl IntoIterator<Item = impl Into<WriterFeatures>>, ) -> Self

set the writer features in the protocol action, automatically bumps min_writer_version

pub fn move_table_properties_into_features( self, configuration: &HashMap<String, Option<String>>, ) -> Protocol

Converts existing properties into features if the reader_version is >=3 or writer_version >=7 only converts features that are “true”

pub fn apply_properties_to_protocol( self, new_properties: &HashMap<String, String>, raise_if_not_exists: bool, ) -> DeltaResult<Protocol>

Will apply the properties to the protocol by either bumping the version or setting features

pub fn enable_timestamp_ntz(self) -> Protocol

Enable timestamp_ntz in the protocol

Trait Implementations

impl Clone for Protocol

fn clone(&self) -> Protocol

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Protocol

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

Formats the value using the given formatter.

impl Default for Protocol

fn default() -> Protocol

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Protocol

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<Protocol> for Action

fn from(a: Protocol) -> Self

Converts to this type from the input type.

impl PartialEq for Protocol

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for Protocol

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for Protocol

impl StructuralPartialEq for Protocol