Enum dataflow_types::sources::KeyEnvelope [−][src]
pub enum KeyEnvelope {
None,
Flattened,
LegacyUpsert,
Named(String),
}
Expand description
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
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl RefUnwindSafe for KeyEnvelope
impl Send for KeyEnvelope
impl Sync for KeyEnvelope
impl Unpin for KeyEnvelope
impl UnwindSafe for KeyEnvelope
Blanket Implementations
Mutably borrows from an owned value. Read more
Compare self to key
and return true
if they are equal.
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more