关注 spark技术分享,
撸spark源码 玩spark最佳实践

DeclarativeAggregate Contract — Unevaluable Aggregate Function Expressions

DeclarativeAggregate Contract — Unevaluable Aggregate Function Expressions

DeclarativeAggregate is an extension of the AggregateFunction Contract for aggregate function expressions that are unevaluable and use expressions for evaluation.

Note
An unevaluable expression cannot be evaluated to produce a value (neither in interpreted nor code-generated expression evaluations) and has to be resolved (replaced) to some other expressions or logical operators at analysis or optimization phases or they fail analysis.
Table 1. DeclarativeAggregate Contract
Property Description

evaluateExpression

The expression that returns the final value for the aggregate function

Used when:

initialValues

mergeExpressions

updateExpressions

Table 2. DeclarativeAggregates (Direct Implementations)
DeclarativeAggregate Description

AggregateWindowFunction

Contract for declarative window aggregate function expressions

Average

CentralMomentAgg

Corr

Count

Covariance

First

Last

Max

Min

SimpleTypedAggregateExpression

Sum

赞(0) 打赏
未经允许不得转载:spark技术分享 » DeclarativeAggregate Contract — Unevaluable Aggregate Function Expressions
分享到: 更多 (0)

关注公众号:spark技术分享

联系我们联系我们

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏