risingwave_pb::stream_plan

Type Alias PbAsOfJoinNode

source
pub type PbAsOfJoinNode = AsOfJoinNode;
Expand description

Alias for AsOfJoinNode.

Aliased Type§

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>,
}

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>