risingwave_pb::stream_plan

Type Alias PbProjectNode

source
pub type PbProjectNode = ProjectNode;
Expand description

Alias for ProjectNode.

Aliased Type§

struct PbProjectNode {
    pub select_list: Vec<ExprNode>,
    pub watermark_input_cols: Vec<u32>,
    pub watermark_output_cols: Vec<u32>,
    pub nondecreasing_exprs: Vec<u32>,
    pub noop_update_hint: bool,
}

Fields§

§select_list: Vec<ExprNode>§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_output_cols: Vec<u32>§nondecreasing_exprs: Vec<u32>§noop_update_hint: bool

Whether there are likely no-op updates in the output chunks, so that eliminating them with StreamChunk::eliminate_adjacent_noop_update could be beneficial.