Struct AggregateState 

struct AggregateState<W>
where
    W: WindowImpl<Key = StateKey, Value = SmallVec<[Datum; 2]>>,
{
    agg_impl: AggImpl,
    arg_data_types: Vec<DataType>,
    ignore_nulls: bool,
    buffer: WindowBuffer<W>,
    buffer_heap_size: KvSize,
}

Fields

agg_impl: AggImpl

arg_data_types: Vec<DataType>

ignore_nulls: bool

buffer: WindowBuffer<W>

buffer_heap_size: KvSize

Implementations

impl<W> AggregateState<W>

where W: WindowImpl<Key = StateKey, Value = SmallVec<[Datum; 2]>>,

fn slide_inner(&mut self) -> StateEvictHint

Trait Implementations

impl<W> EstimateSize for AggregateState<W>

where W: WindowImpl<Key = StateKey, Value = SmallVec<[Datum; 2]>>,

fn estimated_heap_size(&self) -> usize

The estimated heap size of the current struct in bytes.

fn estimated_size(&self) -> usize

where Self: Sized,

The estimated total size of the current struct in bytes, including the estimated_heap_size and the size of Self.

impl<W> WindowState for AggregateState<W>

where W: WindowImpl<Key = StateKey, Value = SmallVec<[Datum; 2]>>,

fn append(&mut self, key: StateKey, args: SmallVec<[Datum; 2]>)

Append a new input row to the state. The key is expected to be increasing.

fn curr_window(&self) -> StatePos<'_>

Get the current window frame position.

fn readiness(&self) -> Readiness

Get the readiness of the current window, given that the rows are appended in the order of the order key, so no future row is less than the last one. Unlike StatePos::is_ready, which is conservative and must not change for the recovery of existing jobs, this is exact.

fn is_empty(&self) -> bool

Whether no row is retained in the state.

fn slide(&mut self) -> Result<(Datum, StateEvictHint)>

Slide the window frame forward and collect the output and evict hint. Similar to Iterator::next.

fn slide_no_output(&mut self) -> Result<StateEvictHint>

Slide the window frame forward and collect the evict hint. Don’t calculate the output if possible.

fn enable_persistence(&mut self)

Enable persistence for this window state. When enabled, the state may return CanEvict hints and should support snapshot/restore.

fn snapshot(&self) -> Option<WindowStateSnapshot>

Create a snapshot of the current state for persistence. Returns None if the state doesn’t support persistence.

fn restore(&mut self, _snapshot: WindowStateSnapshot) -> Result<(), ExprError>

Restore the state from a snapshot. Called during recovery before replaying rows.