risingwave_pb::stream_plan

Type Alias PbHashAggNode

source 
pub type PbHashAggNode = HashAggNode;
Expand description

Alias for HashAggNode.

Aliased Type§

struct PbHashAggNode {
    pub group_key: Vec<u32>,
    pub agg_calls: Vec<AggCall>,
    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 emit_on_window_close: bool,
    pub version: i32,
}

Fields§

§group_key: Vec<u32>§agg_calls: Vec<AggCall>§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§emit_on_window_close: bool§version: i32