Enum dataflow_types::SourceDataEncoding

pub enum SourceDataEncoding {
    Single(DataEncoding),
    KeyValue {
        key: DataEncoding,
        value: DataEncoding,
    },
}

A description of how to interpret data from various sources

Almost all sources only present values as part of their records, but Kafka allows a key to be associated with each record, which has a possibly independent encoding.

Variants

Single(DataEncoding)

Tuple Fields

0: DataEncoding

KeyValue

Fields

key: DataEncoding

value: DataEncoding

Implementations

impl SourceDataEncoding

pub fn key_ref(&self) -> Option<&DataEncoding>

pub fn value(self) -> DataEncoding

Return either the Single encoding if this was a SourceDataEncoding::Single, else return the value encoding

pub fn value_ref(&self) -> &DataEncoding

pub fn desc(&self) -> Result<(Option<RelationDesc>, RelationDesc), Error>

Trait Implementations

impl Clone for SourceDataEncoding

fn clone(&self) -> SourceDataEncoding

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SourceDataEncoding

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SourceDataEncoding

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

Deserialize this value from the given Serde deserializer.

impl Serialize for SourceDataEncoding

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

Serialize this value into the given Serde serializer.