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.

package org.apache.spark.sql.catalyst.expressions

trait SizeBasedWindowFunction extends AggregateWindowFunction {
  // No required properties (vals and methods) that have no implementation
}
Table 1. SizeBasedWindowFunction Contract
Property Description

n

Size of the current window as a AttributeReference expression with window__partition__size name, IntegerType data type and not nullable
Table 2. SizeBasedWindowFunctions (Direct Implementations)
SizeBasedWindowFunction Description

CumeDist

Window function expression for cume_dist standard function (Dataset API) and cume_dist SQL function

NTile

PercentRank

results matching ""

    No results matching ""