Struct ExecutorInner

struct ExecutorInner<S: StateStore> {

    version: PbAggNodeVersion,
    actor_ctx: ActorContextRef,
    info: ExecutorInfo,
    input_pk_indices: Vec<usize>,
    input_schema: Schema,
    agg_calls: Vec<AggCall>,
    agg_funcs: Vec<BoxedAggregateFunction>,
    row_count_index: usize,
    storages: Vec<AggStateStorage<S>>,
    intermediate_state_table: StateTable<S>,
    distinct_dedup_tables: HashMap<usize, StateTable<S>>,
    watermark_epoch: AtomicU64Ref,
    extreme_cache_size: usize,
    must_output_per_barrier: bool,
}

Fields

version: PbAggNodeVersion

Version of aggregation executors.

actor_ctx: ActorContextRef

info: ExecutorInfo

input_pk_indices: Vec<usize>

Pk indices from input. Only used by AggNodeVersion before ISSUE_13465.

input_schema: Schema

Schema from input.

agg_calls: Vec<AggCall>

An operator will support multiple aggregation calls.

agg_funcs: Vec<BoxedAggregateFunction>

Aggregate functions.

row_count_index: usize

Index of row count agg call (count(*)) in the call list.

storages: Vec<AggStateStorage<S>>

State storage for each agg calls.

intermediate_state_table: StateTable<S>

Intermediate state table for value-state agg calls. The state of all value-state aggregates are collected and stored in this table when flush_data is called.

distinct_dedup_tables: HashMap<usize, StateTable<S>>

State tables for deduplicating rows on distinct key for distinct agg calls. One table per distinct column (may be shared by multiple agg calls).

watermark_epoch: AtomicU64Ref

Watermark epoch.

extreme_cache_size: usize

Extreme state cache size

must_output_per_barrier: bool

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

Implementations

impl<S: StateStore> ExecutorInner<S>

fn all_state_tables_mut(&mut self) -> impl Iterator<Item = &mut StateTable<S>>