risingwave_pb::stream_plan

Type Alias PbProjectSetNode

source
pub type PbProjectSetNode = ProjectSetNode;
Expand description

Alias for ProjectSetNode.

Aliased Type§

struct PbProjectSetNode {
    pub select_list: Vec<ProjectSetSelectItem>,
    pub watermark_input_cols: Vec<u32>,
    pub watermark_expr_indices: Vec<u32>,
    pub nondecreasing_exprs: Vec<u32>,
}

Fields§

§select_list: Vec<ProjectSetSelectItem>§watermark_input_cols: Vec<u32>

this two field is expressing a list of usize pair, which means when project receives a watermark with watermark_input_cols\[i\] column index, it should derive a new watermark with watermark_output_cols\[i\]th expression

§watermark_expr_indices: Vec<u32>§nondecreasing_exprs: Vec<u32>