AsOfRowEncoding

risingwave_stream::executor::join::asof_join

Trait AsOfRowEncoding 

Source 
pub trait AsOfRowEncoding:
    'static
    + Send
    + Sync {
    type Encoded: EstimateSize + Clone + Send + Sync;

    // Required methods
    fn encode(row: &OwnedRow) -> Self::Encoded;
    fn decode(encoded: &Self::Encoded, data_types: &[DataType]) -> OwnedRow;
}
Expand description

Trait for encoding/decoding cached AsOf join rows. Unlike JoinEncoding, this doesn’t carry degree since AsOf join has no degree tracking.

Required Associated Types§

Source

type Encoded: EstimateSize + Clone + Send + Sync

Required Methods§

Source

fn encode(row: &OwnedRow) -> Self::Encoded

Source

fn decode(encoded: &Self::Encoded, data_types: &[DataType]) -> OwnedRow

Decode an encoded value back to OwnedRow.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§