risingwave_pb::stream_plan

Type Alias PbSimpleAggNode

source 
pub type PbSimpleAggNode = SimpleAggNode;
Expand description

Alias for SimpleAggNode.

Aliased Type§

struct PbSimpleAggNode {
    pub agg_calls: Vec<AggCall>,
    pub distribution_key: Vec<u32>,
    pub agg_call_states: Vec<AggCallState>,
    pub intermediate_state_table: Option<Table>,
    pub is_append_only: bool,
    pub distinct_dedup_tables: HashMap<u32, Table>,
    pub row_count_index: u32,
    pub version: i32,
    pub must_output_per_barrier: bool,
}

Fields§

§agg_calls: Vec<AggCall>§distribution_key: Vec<u32>

Only used for stateless simple agg.

§agg_call_states: Vec<AggCallState>§intermediate_state_table: Option<Table>§is_append_only: bool

Whether to optimize for append only stream. It is true when the input is append-only

§distinct_dedup_tables: HashMap<u32, Table>§row_count_index: u32§version: i32§must_output_per_barrier: bool

Required by the downstream RowMergeNode, currently only used by the approx_percentile’s two phase plan