Struct FirstValueF64DynAccumulator 

pub struct FirstValueF64DynAccumulator { /* private fields */ }

FIRST_VALUE accumulator for f64 columns via DynAccumulator.

Implementations

impl FirstValueF64DynAccumulator

pub fn new(value_column_index: usize, timestamp_column_index: usize) -> Self

Creates a new FIRST_VALUE dyn accumulator.

Trait Implementations

impl Clone for FirstValueF64DynAccumulator

fn clone(&self) -> FirstValueF64DynAccumulator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FirstValueF64DynAccumulator

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

Formats the value using the given formatter.

impl DynAccumulator for FirstValueF64DynAccumulator

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).