org.apache.spark.sql.execution

Class Aggregate.ComputedAggregate

Object

org.apache.spark.sql.execution.Aggregate.ComputedAggregate

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

Aggregate

public class Aggregate.ComputedAggregate
extends Object
implements scala.Product, scala.Serializable

An aggregate that needs to be computed for each row in a group.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Aggregate.ComputedAggregate(org.apache.spark.sql.catalyst.expressions.AggregateExpression unbound, org.apache.spark.sql.catalyst.expressions.AggregateExpression aggregate, org.apache.spark.sql.catalyst.expressions.AttributeReference resultAttribute)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.expressions.AggregateExpression	aggregate()
org.apache.spark.sql.catalyst.expressions.AttributeReference	resultAttribute()
org.apache.spark.sql.catalyst.expressions.AggregateExpression	unbound()

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

Aggregate.ComputedAggregate

public Aggregate.ComputedAggregate(org.apache.spark.sql.catalyst.expressions.AggregateExpression unbound,
                           org.apache.spark.sql.catalyst.expressions.AggregateExpression aggregate,
                           org.apache.spark.sql.catalyst.expressions.AttributeReference resultAttribute)

Method Detail

unbound

public org.apache.spark.sql.catalyst.expressions.AggregateExpression unbound()

aggregate

public org.apache.spark.sql.catalyst.expressions.AggregateExpression aggregate()

resultAttribute

public org.apache.spark.sql.catalyst.expressions.AttributeReference resultAttribute()