public final class RollingAggregation extends Object
修饰符和类型 | 方法和描述 |
---|---|
静态 RollingAggregation |
argMax()
最大元素的索引。
|
静态 RollingAggregation |
argMin()
最小元素的索引。
|
静态 RollingAggregation |
collectList()
将值收集到列表中。
|
静态 RollingAggregation |
collectList(NullPolicy nullPolicy)
将值收集到列表中。
|
静态 RollingAggregation |
collectSet()
将值收集到集合中。
|
静态 RollingAggregation |
collectSet(NullPolicy nullPolicy, NullEquality nullEquality, NaNEquality nanEquality)
将值收集到集合中。
|
静态 RollingAggregation |
count()
计数有效(也称为
|
静态 RollingAggregation |
count(NullPolicy nullPolicy)
计算元素的数量。
|
boolean |
equals(Object other) |
int |
hashCode() |
静态 RollingAggregation |
lag(int offset)
在滚动窗口中,返回其后偏移量条目的值;如果超出窗口,则返回 null。
|
静态 RollingAggregation |
lag(int offset, ColumnVector defaultOutput)
在滚动窗口中,返回其后偏移量条目的值;如果超出窗口,则返回 defaultOutput 中对应的值。
|
静态 RollingAggregation |
lead(int offset)
在滚动窗口中,返回其前偏移量条目的值;如果超出窗口,则返回 null。
|
静态 RollingAggregation |
lead(int offset, ColumnVector defaultOutput)
在滚动窗口中,返回其前偏移量条目的值;如果超出窗口,则返回 defaultOutput 中对应的值。
|
静态 RollingAggregation |
max()
滚动窗口最大值
|
静态 RollingAggregation |
mean()
算术平均值
|
静态 RollingAggregation |
min()
滚动窗口最小值
|
静态 RollingAggregation |
nth(int n, NullPolicy nullPolicy)
从指定窗口中选择第 n 个元素。
|
RollingAggregationOnColumn |
onColumn(int columnIndex)
向聚合添加一列,以便其可用于数据的特定列。
|
静态 RollingAggregation |
rowNumber()
获取行号。
|
静态 RollingAggregation |
standardDeviation()
滚动窗口标准差,自由度 delta 为 1 (DDOF)。
|
静态 RollingAggregation |
standardDeviation(int ddof)
滚动窗口标准差,可配置自由度 delta (DDOF)。
|
静态 RollingAggregation |
sum()
滚动窗口总和
|
public RollingAggregationOnColumn onColumn(int columnIndex)
columnIndex
- 要操作的列的索引。public static RollingAggregation sum()
public static RollingAggregation min()
public static RollingAggregation max()
public static RollingAggregation standardDeviation()
public static RollingAggregation standardDeviation(int ddof)
public static RollingAggregation count()
public static RollingAggregation count(NullPolicy nullPolicy)
nullPolicy
- 如果应计算 null,则为 INCLUDE。如果只应计算非 null 值,则为 EXCLUDE。public static RollingAggregation mean()
public static RollingAggregation argMax()
public static RollingAggregation argMin()
public static RollingAggregation rowNumber()
public static RollingAggregation lead(int offset)
public static RollingAggregation lead(int offset, ColumnVector defaultOutput)
public static RollingAggregation lag(int offset)
public static RollingAggregation lag(int offset, ColumnVector defaultOutput)
public static RollingAggregation collectList()
public static RollingAggregation collectList(NullPolicy nullPolicy)
nullPolicy
- 指示在收集期间是否包含/排除 null。public static RollingAggregation collectSet()
public static RollingAggregation collectSet(NullPolicy nullPolicy, NullEquality nullEquality, NaNEquality nanEquality)
nullPolicy
- 指示在收集期间是否包含/排除 null。nullEquality
- 用于指定列表中的 null 条目是否应被视为相等的标志。nanEquality
- 用于指定浮点列中的 NaN 值是否应被视为相等的标志。public static RollingAggregation nth(int n, NullPolicy nullPolicy)
n
- 指示要从窗口中选择的元素的索引。nullPolicy
- 指示 null 元素是否应被跳过。版权所有 © 2025。保留所有权利。