Enum ExecutionState 

pub(crate) enum ExecutionState {
    ReadingInput,
    ProducingOutput(RecordBatch),
    SkippingAggregation,
    Done,
}

This object tracks the aggregation phase (input/output)

Variants

ReadingInput

ProducingOutput(RecordBatch)

When producing output, the remaining rows to output are stored here and are sliced off as needed in batch_size chunks

SkippingAggregation

Produce intermediate aggregate state for each input row without aggregation.

See “partial aggregation” discussion on GroupedHashAggregateStream

Done

All input has been consumed and all groups have been emitted

Trait Implementations

impl Clone for ExecutionState

fn clone(&self) -> ExecutionState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExecutionState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.