risingwave_pb::stream_plan

Type Alias PbLookupNode

source
pub type PbLookupNode = LookupNode;
Expand description

Alias for LookupNode.

Aliased Type§

struct PbLookupNode {
    pub arrange_key: Vec<i32>,
    pub stream_key: Vec<i32>,
    pub use_current_epoch: bool,
    pub column_mapping: Vec<i32>,
    pub arrangement_table_info: Option<ArrangementInfo>,
    pub arrangement_table_id: Option<ArrangementTableId>,
}

Fields§

§arrange_key: Vec<i32>

Join key of the arrangement side

§stream_key: Vec<i32>

Join key of the stream side

§use_current_epoch: bool

Whether to join the current epoch of arrangement

§column_mapping: Vec<i32>

Sometimes we need to re-order the output data to meet the requirement of schema. By default, lookup executor will produce <arrangement side, stream side>. We will then apply the column mapping to the combined result.

§arrangement_table_info: Option<ArrangementInfo>

Info about the arrangement

§arrangement_table_id: Option<ArrangementTableId>