public class Window
extends Object
// PARTITION BY country ORDER BY date ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW
Window.partitionBy("country").orderBy("date").rowsBetween(Long.MinValue, 0)
// PARTITION BY country ORDER BY date ROWS BETWEEN 3 PRECEDING AND 3 FOLLOWING
Window.partitionBy("country").orderBy("date").rowsBetween(-3, 3)
Modifier and Type | Method and Description |
---|---|
static WindowSpec |
orderBy(Column... cols)
Creates a
WindowSpec with the ordering defined. |
static WindowSpec |
orderBy(scala.collection.Seq<Column> cols)
Creates a
WindowSpec with the ordering defined. |
static WindowSpec |
orderBy(String colName,
scala.collection.Seq<String> colNames)
Creates a
WindowSpec with the ordering defined. |
static WindowSpec |
orderBy(String colName,
String... colNames)
Creates a
WindowSpec with the ordering defined. |
static WindowSpec |
partitionBy(Column... cols)
Creates a
WindowSpec with the partitioning defined. |
static WindowSpec |
partitionBy(scala.collection.Seq<Column> cols)
Creates a
WindowSpec with the partitioning defined. |
static WindowSpec |
partitionBy(String colName,
scala.collection.Seq<String> colNames)
Creates a
WindowSpec with the partitioning defined. |
static WindowSpec |
partitionBy(String colName,
String... colNames)
Creates a
WindowSpec with the partitioning defined. |
public static WindowSpec partitionBy(String colName, String... colNames)
WindowSpec
with the partitioning defined.colName
- (undocumented)colNames
- (undocumented)public static WindowSpec partitionBy(Column... cols)
WindowSpec
with the partitioning defined.cols
- (undocumented)public static WindowSpec orderBy(String colName, String... colNames)
WindowSpec
with the ordering defined.colName
- (undocumented)colNames
- (undocumented)public static WindowSpec orderBy(Column... cols)
WindowSpec
with the ordering defined.cols
- (undocumented)public static WindowSpec partitionBy(String colName, scala.collection.Seq<String> colNames)
WindowSpec
with the partitioning defined.colName
- (undocumented)colNames
- (undocumented)public static WindowSpec partitionBy(scala.collection.Seq<Column> cols)
WindowSpec
with the partitioning defined.cols
- (undocumented)public static WindowSpec orderBy(String colName, scala.collection.Seq<String> colNames)
WindowSpec
with the ordering defined.colName
- (undocumented)colNames
- (undocumented)public static WindowSpec orderBy(scala.collection.Seq<Column> cols)
WindowSpec
with the ordering defined.cols
- (undocumented)