public final class ReductionAggregation extends Object
修饰符和类型 | 方法和说明 |
---|---|
static ReductionAggregation |
all()
All 归约。
|
static ReductionAggregation |
any()
Any 归约。
|
static ReductionAggregation |
collectList() |
static ReductionAggregation |
collectList(NullPolicy nullPolicy)
将值收集到列表中。
|
static ReductionAggregation |
collectSet()
将值收集到集合中。
|
static ReductionAggregation |
collectSet(NullPolicy nullPolicy, NullEquality nullEquality, NaNEquality nanEquality)
将值收集到集合中。
|
static ReductionAggregation |
createTDigest(int delta)
tDigest 归约。
|
boolean |
equals(Object other) |
int |
hashCode() |
static ReductionAggregation |
histogram()
创建 HistogramAggregation,计算每行唯一值的频率。
|
static ReductionAggregation |
hostUDF(HostUDFWrapper wrapper)
使用主机端用户定义函数 (UDF) 执行归约。
|
static ReductionAggregation |
max()
最大值聚合
|
static ReductionAggregation |
mean()
算术平均值归约。
|
static ReductionAggregation |
median()
中位数归约。
|
static ReductionAggregation |
mergeHistogram()
创建 MergeHistogramAggregation,用于合并多个直方图。
|
static ReductionAggregation |
mergeLists()
合并由多个 CollectListAggregations 产生的部分列表。
|
static ReductionAggregation |
mergeSets()
合并由多个 CollectSetAggregations 产生的部分集合。
|
static ReductionAggregation |
mergeSets(NullEquality nullEquality, NaNEquality nanEquality)
合并由多个 CollectSetAggregations 产生的部分集合。
|
static ReductionAggregation |
mergeTDigest(int delta)
tDigest 合并归约。
|
static ReductionAggregation |
min()
最小值聚合
|
static ReductionAggregation |
nth(int offset)
获取组中第 n 个非空元素。
|
static ReductionAggregation |
nth(int offset, NullPolicy nullPolicy)
获取组中第 n 个元素。
|
static ReductionAggregation |
nunique()
非空唯一元素的数量。
|
static ReductionAggregation |
nunique(NullPolicy nullPolicy)
唯一元素的数量。
|
static ReductionAggregation |
product()
乘积聚合。
|
static ReductionAggregation |
quantile(double... quantiles)
聚合计算指定的分位数。
|
static ReductionAggregation |
quantile(QuantileMethod method, double... quantiles)
聚合计算各种分位数。
|
static ReductionAggregation |
standardDeviation()
自由度差为 1 的标准差聚合。
|
static ReductionAggregation |
standardDeviation(int ddof)
标准差聚合。
|
static ReductionAggregation |
sum()
求和聚合
|
static ReductionAggregation |
sumOfSquares()
平方和归约。
|
static ReductionAggregation |
variance()
自由度差为 1 的方差聚合。
|
static ReductionAggregation |
variance(int ddof)
方差聚合。
|
public static ReductionAggregation sum()
public static ReductionAggregation product()
public static ReductionAggregation min()
public static ReductionAggregation max()
public static ReductionAggregation any()
public static ReductionAggregation all()
public static ReductionAggregation sumOfSquares()
public static ReductionAggregation mean()
public static ReductionAggregation variance()
public static ReductionAggregation variance(int ddof)
ddof
- 自由度差。方差计算中使用的除数是 N - ddof
,其中 N 是总体大小。public static ReductionAggregation standardDeviation()
public static ReductionAggregation standardDeviation(int ddof)
ddof
- 自由度差。标准差计算中使用的除数是 N - ddof
,其中 N 是总体大小。public static ReductionAggregation median()
public static ReductionAggregation quantile(double... quantiles)
public static ReductionAggregation quantile(QuantileMethod method, double... quantiles)
public static ReductionAggregation nunique()
public static ReductionAggregation nunique(NullPolicy nullPolicy)
nullPolicy
- 如果应计算 null 值则为 INCLUDE,否则为 EXCLUDE。如果计算 null 值,则它们被视为相等,因此范围内的多个 null 值只会使计数增加 1。public static ReductionAggregation nth(int offset)
offset
- 要查看的偏移量。负数表示从组末尾开始计数。任何超出组范围的值都会导致 null。public static ReductionAggregation nth(int offset, NullPolicy nullPolicy)
offset
- 要查看的偏移量。负数表示从组末尾开始计数。任何超出组范围的值都会导致 null。nullPolicy
- 如果 null 值应包含在聚合中则为 INCLUDE,如果应跳过则为 EXCLUDE。public static ReductionAggregation createTDigest(int delta)
public static ReductionAggregation mergeTDigest(int delta)
public static ReductionAggregation collectList()
public static ReductionAggregation collectList(NullPolicy nullPolicy)
nullPolicy
- 指示在收集期间是否包含/排除 null 值。public static ReductionAggregation collectSet()
public static ReductionAggregation collectSet(NullPolicy nullPolicy, NullEquality nullEquality, NaNEquality nanEquality)
nullPolicy
- 指示在收集期间是否包含/排除 null 值。nullEquality
- 标志,指定列表中 null 条目是否应被视为相等。nanEquality
- 标志,指定浮点列中的 NaN 值是否应被视为相等。public static ReductionAggregation mergeLists()
public static ReductionAggregation mergeSets()
public static ReductionAggregation mergeSets(NullEquality nullEquality, NaNEquality nanEquality)
nullEquality
- 标志,指定列表中 null 条目是否应被视为相等。nanEquality
- 标志,指定浮点列中的 NaN 值是否应被视为相等。public static ReductionAggregation hostUDF(HostUDFWrapper wrapper)
wrapper
- 本地主机 UDF 实例的包装器。public static ReductionAggregation histogram()
public static ReductionAggregation mergeHistogram()
版权所有 © 2025。保留所有权利。