Struct CountDynAccumulator 

pub struct CountDynAccumulator { /* private fields */ }

Count accumulator implementing DynAccumulator.

Trait Implementations

impl Clone for CountDynAccumulator

fn clone(&self) -> CountDynAccumulator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CountDynAccumulator

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

Formats the value using the given formatter.

impl Default for CountDynAccumulator

fn default() -> CountDynAccumulator

Returns the “default value” for a type.

impl DynAccumulator for CountDynAccumulator

fn add_event(&mut self, event: &Event)

Adds an event to the accumulator.

fn merge_dyn(&mut self, other: &dyn DynAccumulator)

Merges another accumulator of the same type into this one.

fn result_scalar(&self) -> ScalarResult

Returns the current aggregate result.

fn is_empty(&self) -> bool

Returns true if no values have been accumulated.

fn clone_box(&self) -> Box<dyn DynAccumulator>

Creates a boxed clone of this accumulator.

fn serialize(&self) -> Vec<u8>

Serializes the accumulator state to bytes (for checkpointing).

fn result_field(&self) -> Field

Returns the Arrow field descriptor for this accumulator’s output.

fn type_tag(&self) -> &'static str

Returns a type tag for deserialization dispatch.

fn as_any(&self) -> &dyn Any

Returns self as Any for downcasting (used by DataFusion bridge).