WindowSpec

org.apache.spark.sql.expressions.WindowSpec
See theWindowSpec companion object
class WindowSpec

A window specification that defines the partitioning, ordering, and frame boundaries of an analytic / windowed computation. Build with Window.

 import org.apache.spark.sql.expressions.Window
 import org.apache.spark.sql.functions._
 val w = Window.partitionBy("dept").orderBy(col("salary").desc)
 df.select(col("*"), rank().over(w).as("r"))

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def orderBy(colName: String, colNames: String*): WindowSpec
def orderBy(cols: Column*): WindowSpec
def partitionBy(colName: String, colNames: String*): WindowSpec
def rangeBetween(start: Long, end: Long): WindowSpec
def rowsBetween(start: Long, end: Long): WindowSpec