Skip to main content

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".

Implementors§