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


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


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



results matching ""

    No results matching ""