Enum mz_storage::upsert::types::Value

pub enum Value<T, O> {
    FinalizedValue(Result<Row, UpsertError>, O),
    Tombstone(O),
    ProvisionalValue {
        finalized_value: Option<Box<(Result<Row, UpsertError>, O)>>,
        provisional_value: (Option<Result<Row, UpsertError>>, T, O),
    },
}

A totally consolidated value stored within the UpsertStateBackend.

This type contains support for tombstones, that contain an order key, and provisional values.

What is considered finalized and provisional depends on the implementation of the UPSERT operator: it might consider everything that it writes to its state finalized, and assume that what it emits will be written down in the output exactly as presented. Or it might consider everything it writes down provisional, and only consider updates that it knows to be persisted as finalized.

Provisional values should only be considered while still “working off” updates with the same timestamp at which the provisional update was recorded.

Variants

FinalizedValue(Result<Row, UpsertError>, O)

Tombstone(O)

ProvisionalValue

Fields

finalized_value: Option<Box<(Result<Row, UpsertError>, O)>>

provisional_value: (Option<Result<Row, UpsertError>>, T, O)

Trait Implementations

impl<T: Clone, O: Clone> Clone for Value<T, O>

fn clone(&self) -> Value<T, O>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug, O: Debug> Debug for Value<T, O>

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

Formats the value using the given formatter.

impl<'de, T, O> Deserialize<'de> for Value<T, O>

where T: Deserialize<'de>, O: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T, O> Serialize for Value<T, O>

where T: Serialize, O: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.