risingwave_pb::stream_plan

Type Alias PbAsOfJoinNode

Source 
pub type PbAsOfJoinNode = AsOfJoinNode;

Aliased Type§

pub struct PbAsOfJoinNode {
    pub join_type: i32,
    pub left_key: Vec<i32>,
    pub right_key: Vec<i32>,
    pub left_table: Option<Table>,
    pub right_table: Option<Table>,
    pub output_indices: Vec<u32>,
    pub left_deduped_input_pk_indices: Vec<u32>,
    pub right_deduped_input_pk_indices: Vec<u32>,
    pub null_safe: Vec<bool>,
    pub asof_desc: Option<AsOfJoinDesc>,
    pub join_encoding_type: i32,
}

Fields§

§join_type: i32§left_key: Vec<i32>§right_key: Vec<i32>§left_table: Option<Table>

Used for internal table states.

§right_table: Option<Table>

Used for internal table states.

§output_indices: Vec<u32>

The output indices of current node

§left_deduped_input_pk_indices: Vec<u32>

Left deduped input pk indices. The pk of the left_table and The pk of the left_table is [left_join_key | left_inequality_key | left_deduped_input_pk_indices] left_inequality_key is not used but for forward compatibility.

§right_deduped_input_pk_indices: Vec<u32>

Right deduped input pk indices. The pk of the right_table is [right_join_key | right_inequality_key | right_deduped_input_pk_indices] right_inequality_key is not used but for forward compatibility.

§null_safe: Vec<bool>§asof_desc: Option<AsOfJoinDesc>§join_encoding_type: i32

Which encoding will be used to encode join rows in operator cache.