PbHashAggNode

risingwave_pb::stream_plan

Type Alias PbHashAggNode 

Source 
pub type PbHashAggNode = HashAggNode;

Aliased Type§

pub 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