spark技术分享SizeBasedWindowFunction Contract — Declarative Window Aggregate Functions with Window Size
SizeBasedWindowFunction is the extension of the AggregateWindowFunction Contract for window functions that require the size of the current window for calculation.
|
1 2 3 4 5 6 7 8 9 |
package org.apache.spark.sql.catalyst.expressions trait SizeBasedWindowFunction extends AggregateWindowFunction { // No required properties (vals and methods) that have no implementation } |
| Property | Description |
|---|---|
|
|
Size of the current window as a AttributeReference expression with |
| SizeBasedWindowFunction | Description |
|---|---|
|
Window function expression for cume_dist standard function (Dataset API) and cume_dist SQL function |
|
|
NTile |
|
|
PercentRank |
