Evaluates bound aggregates over StructLike data. More...

#include <aggregate.h>

Public Member Functions
virtual Status	Update (const StructLike &data)=0
	Update aggregates with a row.

virtual Status	Update (const DataFile &file)=0
	Update aggregates using data file metrics.

virtual Result< std::span< const Literal > >	GetResults () const =0
	Final aggregated value.

virtual Result< Literal >	GetResult () const =0
	Convenience accessor when only one aggregate is evaluated.

virtual bool	AllAggregatorsValid () const =0
	Whether all aggregators are still valid (metrics present).

Static Public Member Functions
static Result< std::unique_ptr< AggregateEvaluator > >	Make (std::shared_ptr< BoundAggregate > aggregate)
	Create an evaluator for a single bound aggregate.

static Result< std::unique_ptr< AggregateEvaluator > >	Make (std::vector< std::shared_ptr< BoundAggregate > > aggregates)
	Create an evaluator for multiple bound aggregates.

Detailed Description

Evaluates bound aggregates over StructLike data.

Member Function Documentation

Result< std::unique_ptr< AggregateEvaluator > > iceberg::AggregateEvaluator::Make ( std::shared_ptr< BoundAggregate > aggregate )

static

Create an evaluator for a single bound aggregate.

Parameters

aggregate The bound aggregate to evaluate across rows.

Result< std::unique_ptr< AggregateEvaluator > > iceberg::AggregateEvaluator::Make ( std::vector< std::shared_ptr< BoundAggregate > > aggregates )

static

Create an evaluator for multiple bound aggregates.

Parameters

aggregates Aggregates to evaluate in one pass; order is preserved in Results().

The documentation for this class was generated from the following files: