public class WindowSpec
extends Object
Use the static methods in Window
to create a WindowSpec
.
Modifier and Type | Method and Description |
---|---|
WindowSpec |
orderBy(Column... cols)
Defines the ordering columns in a
WindowSpec . |
WindowSpec |
orderBy(scala.collection.Seq<Column> cols)
Defines the ordering columns in a
WindowSpec . |
WindowSpec |
orderBy(String colName,
scala.collection.Seq<String> colNames)
Defines the ordering columns in a
WindowSpec . |
WindowSpec |
orderBy(String colName,
String... colNames)
Defines the ordering columns in a
WindowSpec . |
WindowSpec |
partitionBy(Column... cols)
Defines the partitioning columns in a
WindowSpec . |
WindowSpec |
partitionBy(scala.collection.Seq<Column> cols)
Defines the partitioning columns in a
WindowSpec . |
WindowSpec |
partitionBy(String colName,
scala.collection.Seq<String> colNames)
Defines the partitioning columns in a
WindowSpec . |
WindowSpec |
partitionBy(String colName,
String... colNames)
Defines the partitioning columns in a
WindowSpec . |
WindowSpec |
rangeBetween(long start,
long end)
Defines the frame boundaries, from
start (inclusive) to end (inclusive). |
WindowSpec |
rowsBetween(long start,
long end)
Defines the frame boundaries, from
start (inclusive) to end (inclusive). |
public WindowSpec partitionBy(String colName, String... colNames)
WindowSpec
.colName
- (undocumented)colNames
- (undocumented)public WindowSpec partitionBy(Column... cols)
WindowSpec
.cols
- (undocumented)public WindowSpec orderBy(String colName, String... colNames)
WindowSpec
.colName
- (undocumented)colNames
- (undocumented)public WindowSpec orderBy(Column... cols)
WindowSpec
.cols
- (undocumented)public WindowSpec partitionBy(String colName, scala.collection.Seq<String> colNames)
WindowSpec
.colName
- (undocumented)colNames
- (undocumented)public WindowSpec partitionBy(scala.collection.Seq<Column> cols)
WindowSpec
.cols
- (undocumented)public WindowSpec orderBy(String colName, scala.collection.Seq<String> colNames)
WindowSpec
.colName
- (undocumented)colNames
- (undocumented)public WindowSpec orderBy(scala.collection.Seq<Column> cols)
WindowSpec
.cols
- (undocumented)public WindowSpec rowsBetween(long start, long end)
start
(inclusive) to end
(inclusive).
Both start
and end
are relative positions from the current row. For example, "0" means
"current row", while "-1" means the row before the current row, and "5" means the fifth row
after the current row.
start
- boundary start, inclusive.
The frame is unbounded if this is the minimum long value.end
- boundary end, inclusive.
The frame is unbounded if this is the maximum long value.public WindowSpec rangeBetween(long start, long end)
start
(inclusive) to end
(inclusive).
Both start
and end
are relative from the current row. For example, "0" means "current row",
while "-1" means one off before the current row, and "5" means the five off after the
current row.
start
- boundary start, inclusive.
The frame is unbounded if this is the minimum long value.end
- boundary end, inclusive.
The frame is unbounded if this is the maximum long value.