Enum Op

pub enum Op {
    Insert,
    Delete,
    UpdateDelete,
    UpdateInsert,
}

Op represents three operations in StreamChunk.

UpdateDelete and UpdateInsert are semantically equivalent to Delete and Insert but always appear in pairs to represent an update operation. For example, table source, aggregation and outer join can generate updates by themselves, while most of the other operators only pass through updates with best effort.

Variants

Insert

Delete

UpdateDelete

UpdateInsert

Implementations

impl Op

pub fn is_insert(&self) -> bool

Returns true if this is a Op::Insert, otherwise false

pub fn is_delete(&self) -> bool

Returns true if this is a Op::Delete, otherwise false

pub fn is_update_delete(&self) -> bool

Returns true if this is a Op::UpdateDelete, otherwise false

pub fn is_update_insert(&self) -> bool

Returns true if this is a Op::UpdateInsert, otherwise false

impl Op

pub fn to_protobuf(self) -> PbOp

pub fn from_protobuf(prost: &i32) -> ArrayResult<Op>

pub fn normalize_update(self) -> Op

convert UpdateDelete to Delete and UpdateInsert to Insert

pub fn to_i16(self) -> i16

pub fn to_varchar(self) -> String

Trait Implementations

impl Clone for Op

fn clone(&self) -> Op

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Op

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

Formats the value using the given formatter.

impl Hash for Op

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 Ord for Op

fn cmp(&self, other: &Op) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for Op

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

fn partial_cmp(&self, other: &Op) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Copy for Op

impl Eq for Op

impl StructuralPartialEq for Op