Package org.apache.iceberg.expressions

Class AggregateEvaluator

java.lang.Object

org.apache.iceberg.expressions.AggregateEvaluator

public class AggregateEvaluator
extends Object

A class for evaluating aggregates. It evaluates each of the aggregates and updates the aggregated value. The final aggregated result can be returned by result().

Method Summary

Modifier and Type	Method	Description
List<BoundAggregate<?,?>>	aggregates()
boolean	allAggregatorsValid()
static AggregateEvaluator	create(List<BoundAggregate<?,?>> aggregates)
static AggregateEvaluator	create(Schema schema, List<Expression> aggregates)
StructLike	result()
Types.StructType	resultType()
void	update(DataFile file)
void	update(StructLike struct)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

public static AggregateEvaluator create(Schema schema,
 List<Expression> aggregates)

create

public static AggregateEvaluator create(List<BoundAggregate<?,?>> aggregates)

update

public void update(StructLike struct)

update

public void update(DataFile file)

resultType

public Types.StructType resultType()

allAggregatorsValid

public boolean allAggregatorsValid()

result

public StructLike result()

aggregates

public List<BoundAggregate<?,?>> aggregates()