Enum StreamKind 

pub enum StreamKind {
    Retract,
    AppendOnly,
    Upsert,
}

The kind of the changelog stream output by a stream operator.

Variants

Retract

The stream contains Insert, Delete, UpdateDelete, and UpdateInsert operations.

When a row is going to be updated or deleted, a Delete or UpdateDelete record containing the complete old value will be emitted first, before the new value is emitted as an Insert or UpdateInsert record.

AppendOnly

The stream contains only Insert operations.

Upsert

The stream contains Insert and Delete operations. When a row is going to be updated, only the new value is emitted as an Insert record. When a row is going to be deleted, an incomplete Delete record may be emitted, where only the primary key columns are guaranteed to be set.

Stateful operators typically can not process such streams correctly. It must be converted to Retract before being sent to stateful operators in this case.

Implementations

impl StreamKind

pub fn is_append_only(self) -> bool

Returns true if it’s StreamKind::AppendOnly.

pub fn merge(self, other: Self) -> Self

Returns the stream kind representing the merge (union) of the two.

Note that there should be no conflict on the stream key between the two streams, otherwise it will result in an “inconsistent” stream.

pub fn to_protobuf(self) -> PbStreamKind

Converts the stream kind to the protobuf representation.

Trait Implementations

impl Clone for StreamKind

fn clone(&self) -> StreamKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamKind

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

Formats the value using the given formatter.

impl Display for StreamKind

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

Formats the value using the given formatter.

impl Hash for StreamKind

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for StreamKind

fn eq(&self, other: &StreamKind) -> 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 Copy for StreamKind

impl Eq for StreamKind

impl StructuralPartialEq for StreamKind