Package org.apache.iceberg.expressions

Class CountAggregate<T>

java.lang.Object

org.apache.iceberg.expressions.Aggregate<BoundTerm<T>>

org.apache.iceberg.expressions.BoundAggregate<T,Long>

org.apache.iceberg.expressions.CountAggregate<T>

All Implemented Interfaces:

Serializable, Bound<Long>, Expression

Direct Known Subclasses:

CountNonNull, CountStar

public class CountAggregate<T>
extends BoundAggregate<T,Long>

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.iceberg.expressions.Expression

Expression.Operation

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CountAggregate(Expression.Operation op, BoundTerm<T> term)

Method Summary

Modifier and Type	Method	Description
protected Long	countFor(DataFile file)
protected Long	countFor(StructLike row)
Long	eval(DataFile file)
Long	eval(StructLike struct)	Produce a value from the struct for this expression.
org.apache.iceberg.expressions.BoundAggregate.Aggregator<Long>	newAggregator()

Methods inherited from class org.apache.iceberg.expressions.BoundAggregate

columnName, describe, ref, type

Methods inherited from class org.apache.iceberg.expressions.Aggregate

op, term, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.expressions.Expression

isEquivalentTo, negate

Constructor Details

CountAggregate

protected CountAggregate(Expression.Operation op,
 BoundTerm<T> term)

Method Details

eval

public Long eval(StructLike struct)

Description copied from interface: Bound

Produce a value from the struct for this expression.

Specified by:

eval in interface Bound<T>

Overrides:

eval in class BoundAggregate<T,Long>

Parameters:

struct - a struct of incoming data

Returns:

the value of this expression when evaluated on the incoming struct

eval

public Long eval(DataFile file)

countFor

protected Long countFor(StructLike row)

countFor

protected Long countFor(DataFile file)

newAggregator

public org.apache.iceberg.expressions.BoundAggregate.Aggregator<Long> newAggregator()