Type Params | Return Type | Name and description |
---|---|---|
|
public BigDecimal |
cumeDist() Returns the cumulative distribution of a value in the window |
|
public Long |
denseRank() Returns the dense rank in the window |
<V> |
public V |
firstValue(Function<? super T, ? extends V> extractor) Returns the first value in the window |
<V> |
public V |
lag(Function<? super T, ? extends V> extractor) Returns the previous value in the window, similar to SQL's lag() |
<V> |
public V |
lag(Function<? super T, ? extends V> extractor, long lag) Returns the previous value in the window, similar to SQL's lag() |
<V> |
public V |
lag(Function<? super T, ? extends V> extractor, long lag, V def) Returns the previous value by lag in the window, similar to SQL's lag() |
<V> |
public V |
lastValue(Function<? super T, ? extends V> extractor) Returns the last value in the window |
<V> |
public V |
lead(Function<? super T, ? extends V> extractor) Returns the next value in the window, similar to SQL's lead() |
<V> |
public V |
lead(Function<? super T, ? extends V> extractor, long lead) Returns the next value in the window, similar to SQL's lead() |
<V> |
public V |
lead(Function<? super T, ? extends V> extractor, long lead, V def) Returns the next value by lead in the window, similar to SQL's lead() |
<V> |
public V |
nthValue(Function<? super T, ? extends V> extractor, long index) Returns the nth value in the window |
|
public long |
ntile(long bucketCnt) Distributes rows of an ordered window into a pre-defined number of roughly equal buckets |
<T, U extends Comparable<? super U>> |
public static Window<T> |
of(Tuple2<T, Long> currentRecord, Partition<Tuple2<T, Long>> partition, WindowDefinition<T, U> windowDefinition) Factory method to create Window instance |
|
public BigDecimal |
percentRank() Returns the percent rank in the window |
|
public Long |
rank() Returns the rank in the window |
|
public long |
rowNumber() Returns row number in the window, similar to SQL's row_number() |
Methods inherited from class | Name |
---|---|
interface Queryable |
agg, avg, count, count, crossJoin, distinct, emptyQueryable, exists, from, from, from, from, fullHashJoin, fullJoin, groupBy, groupBy, innerHashJoin, innerJoin, intersect, leftHashJoin, leftJoin, limit, limit, list, max, median, min, minus, orderBy, orderBy, over, rightHashJoin, rightJoin, select, size, stdev, stdevp, stream, sum, toList, union, unionAll, var, varp, where |
Returns the cumulative distribution of a value in the window
Returns the dense rank in the window
Returns the first value in the window
V
- the type of fieldextractor
- field extractor Returns the previous value in the window, similar to SQL's lag()
extractor
- field extractorV
- the type of field Returns the previous value in the window, similar to SQL's lag()
extractor
- field extractorlag
- the offsetV
- the type of field Returns the previous value by lag
in the window, similar to SQL's lag()
V
- the type of fieldextractor
- field extractorlag
- the offsetdef
- the default valuelag
Returns the last value in the window
V
- the type of fieldextractor
- field extractor Returns the next value in the window, similar to SQL's lead()
extractor
- field extractorV
- the type of field Returns the next value in the window, similar to SQL's lead()
extractor
- field extractorlead
- the offsetV
- the type of field Returns the next value by lead
in the window, similar to SQL's lead()
V
- the type of fieldextractor
- field extractorlead
- the offsetdef
- the default valuelead
Returns the nth value in the window
V
- the type of fieldextractor
- field extractorindex
- index for value to fetch, starting with 0
Distributes rows of an ordered window into a pre-defined number of roughly equal buckets
bucketCnt
- bucket count0
Factory method to create Window instance
currentRecord
- current recordpartition
- the partition where the window is constructedwindowDefinition
- window definitionT
- the type of Window elementU
- the type of field to sortReturns the percent rank in the window
Returns the rank in the window
Returns row number in the window, similar to SQL's row_number()