Enum dataflow_types::KeyEnvelope

pub enum KeyEnvelope {
    None,
    Flattened,
    LegacyUpsert,
    Named(String),
}

Whether and how to include the decoded key of a stream in dataflows

Variants

None

Never include the key in the output row

Flattened

For composite key encodings, pull the fields from the encoding into columns.

LegacyUpsert

Upsert is identical to Flattened but differs for non-avro sources, for which key names are overwritten.

Named(String)

Tuple Fields

0: String

Always use the given name for the key.

• For a single-field key, this means that the column will get the given name.
• For a multi-column key, the columns will get packed into a ScalarType::Record, and that Record will get the given name.

Trait Implementations

impl Clone for KeyEnvelope

fn clone(&self) -> KeyEnvelope

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for KeyEnvelope

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for KeyEnvelope

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

Deserialize this value from the given Serde deserializer.

impl PartialEq<KeyEnvelope> for KeyEnvelope

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl Serialize for KeyEnvelope

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 KeyEnvelope

impl StructuralEq for KeyEnvelope

impl StructuralPartialEq for KeyEnvelope