GroupByAggregation (cudfjni 25.04.0 API)

java.lang.Object
- ai.rapids.cudf.GroupByAggregation

public final class GroupByAggregation
extends Object

一种可用于归约的聚合操作。

方法摘要

所有方法静态方法实例方法具体方法
修饰符和类型	方法和说明
`static GroupByAggregation`	`argMax()` 最大元素的索引。
`static GroupByAggregation`	`argMin()` 最小元素的索引。
`static GroupByAggregation`	`collectList()` 将值收集到列表中。
`static GroupByAggregation`	`collectList(NullPolicy nullPolicy)` 将值收集到列表中。
`static GroupByAggregation`	`collectSet()` 将值收集到集合中。
`static GroupByAggregation`	`collectSet(NullPolicy nullPolicy, NullEquality nullEquality, NaNEquality nanEquality)` 将值收集到集合中。
`static GroupByAggregation`	`count()` 计算有效元素的数量，即
`static GroupByAggregation`	`count(NullPolicy nullPolicy)` 计算元素的数量。
`static GroupByAggregation`	`createTDigest(int delta)` 根据固定宽度数字输入列计算 t-digest。
`boolean`	`equals(Object other)`
`int`	`hashCode()`
`static GroupByAggregation`	`histogram()` 直方图聚合，计算每行的频率。
`static GroupByAggregation`	`hostUDF(HostUDFWrapper wrapper)` 使用主机端用户定义函数 (UDF) 执行聚合。
`static GroupByAggregation`	`M2()` 与平均值之差的平方和。
`static GroupByAggregation`	`max()` 最大值聚合
`static GroupByAggregation`	`mean()` 算术平均归约。
`static GroupByAggregation`	`median()` 中位数归约。
`static GroupByAggregation`	`mergeHistogram()` MergeHistogram 聚合，用于合并多个直方图。
`static GroupByAggregation`	`mergeLists()` 合并由多个 CollectListAggregations 产生的部分列表。
`static GroupByAggregation`	`mergeM2()` 合并由多个 M2Aggregation 实例产生的部分 M2 值。
`static GroupByAggregation`	`mergeSets()` 合并由多个 CollectSetAggregations 产生的部分集合。
`static GroupByAggregation`	`mergeSets(NullEquality nullEquality, NaNEquality nanEquality)` 合并由多个 CollectSetAggregations 产生的部分集合。
`static GroupByAggregation`	`mergeTDigest(int delta)` 合并 t-digests。
`static GroupByAggregation`	`min()` 最小值聚合
`static GroupByAggregation`	`nth(int offset)` 获取组中第 n 个非空元素。
`static GroupByAggregation`	`nth(int offset, NullPolicy nullPolicy)` 获取组中第 n 个元素。
`static GroupByAggregation`	`nunique()` 唯一非空元素的数量。
`static GroupByAggregation`	`nunique(NullPolicy nullPolicy)` 唯一元素的数量。
`GroupByAggregationOnColumn`	`onColumn(int columnIndex)` 将列添加到聚合中，以便可以在特定的数据列上使用它。
`static GroupByAggregation`	`product()` 乘积聚合。
`static GroupByAggregation`	`quantile(double... quantiles)` 聚合计算指定的分位数。
`static GroupByAggregation`	`quantile(QuantileMethod method, double... quantiles)` 聚合计算各种分位数。
`static GroupByAggregation`	`standardDeviation()` 自由度偏差为 1 的标准差聚合。
`static GroupByAggregation`	`standardDeviation(int ddof)` 标准差聚合。
`static GroupByAggregation`	`sum()` 求和聚合
`static GroupByAggregation`	`variance()` 自由度偏差为 1 的方差聚合。
`static GroupByAggregation`	`variance(int ddof)` 方差聚合。

继承自类 java.lang.Object 的方法
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

- 方法详情
  - onColumn
```
public GroupByAggregationOnColumn onColumn(int columnIndex)
```
    将列添加到聚合中，以便可以在特定的数据列上使用它。
    
    参数
    
    columnIndex - 要操作的列的索引。
  - hashCode
```
public int hashCode()
```
    覆盖
    
    hashCode 在类 Object 中覆盖
  - equals
```
public boolean equals(Object other)
```
    覆盖
    
    equals 在类 Object 中
  - count
```
public static GroupByAggregation count()
```
    计算有效元素（即非空元素）的数量。
  - count
```
public static GroupByAggregation count(NullPolicy nullPolicy)
```
    计算元素的数量。
    
    参数
    
    nullPolicy - 如果应计算 null 值，则为 INCLUDE。如果仅计算非 null 值，则为 EXCLUDE。
  - sum
```
public static GroupByAggregation sum()
```
    求和聚合
  - product
```
public static GroupByAggregation product()
```
    乘积聚合。
  - argMax
```
public static GroupByAggregation argMax()
```
    最大元素的索引。请注意，使用此聚合时，如果数据尚未按分组键排序，则可能在执行聚合之前自动对其进行排序。这将导致返回排序数据的索引。
  - argMin
```
public static GroupByAggregation argMin()
```
    最小元素的索引。请注意，使用此聚合时，如果数据尚未按分组键排序，则可能在执行聚合之前自动对其进行排序。这将导致返回排序数据的索引。
  - min
```
public static GroupByAggregation min()
```
    最小值聚合
  - max
```
public static GroupByAggregation max()
```
    最大值聚合
  - mean
```
public static GroupByAggregation mean()
```
    算术平均归约。
  - M2
```
public static GroupByAggregation M2()
```
    与平均值之差的平方和。
  - variance
```
public static GroupByAggregation variance()
```
    自由度偏差为 1 的方差聚合。
  - variance
```
public static GroupByAggregation variance(int ddof)
```
    方差聚合。
    
    参数
    
    ddof - 自由度偏差。用于计算方差的除数是 N - ddof，其中 N 是总体大小。
  - standardDeviation
```
public static GroupByAggregation standardDeviation()
```
    自由度偏差为 1 的标准差聚合。
  - standardDeviation
```
public static GroupByAggregation standardDeviation(int ddof)
```
    标准差聚合。
    
    参数
    
    ddof - 自由度偏差。用于计算 std 的除数是 N - ddof，其中 N 是总体大小。
  - quantile
```
public static GroupByAggregation quantile(double... quantiles)
```
    聚合计算指定的分位数。默认使用线性插值。
  - quantile
```
public static GroupByAggregation quantile(QuantileMethod method,
                                          double... quantiles)
```
    聚合计算各种分位数。
  - median
```
public static GroupByAggregation median()
```
    中位数归约。
  - nunique
```
public static GroupByAggregation nunique()
```
    唯一非空元素的数量。
  - nunique
```
public static GroupByAggregation nunique(NullPolicy nullPolicy)
```
    唯一元素的数量。
    
    参数
    
    nullPolicy - 如果应计算 null 值，则为 INCLUDE，否则为 EXCLUDE。如果计算 null 值，它们被视为相等，因此范围内的多个 null 值总计只会使计数增加 1。
  - nth
```
public static GroupByAggregation nth(int offset)
```
    获取组中第 n 个非空元素。
    
    参数
    
    offset - 要查看的偏移量。负数从组的末尾开始计算。任何超出组范围的值都会导致 null。
  - nth
```
public static GroupByAggregation nth(int offset,
                                     NullPolicy nullPolicy)
```
    获取组中第 n 个元素。
    
    参数
    
    offset - 要查看的偏移量。负数从组的末尾开始计算。任何超出组范围的值都会导致 null。
    
    nullPolicy - 如果 null 值应包含在聚合中，则为 INCLUDE；如果应跳过它们，则为 EXCLUDE。
  - collectList
```
public static GroupByAggregation collectList()
```
    将值收集到列表中。Null 值将被跳过。
  - collectList
```
public static GroupByAggregation collectList(NullPolicy nullPolicy)
```
    将值收集到列表中。
    
    参数
    
    nullPolicy - 指示在收集过程中是否包含/排除 null 值。
  - collectSet
```
public static GroupByAggregation collectSet()
```
    将值收集到集合中。所有 null 值都将被排除，所有 NaN 值都被视为唯一实例。
  - collectSet
```
public static GroupByAggregation collectSet(NullPolicy nullPolicy,
                                            NullEquality nullEquality,
                                            NaNEquality nanEquality)
```
    将值收集到集合中。
    
    参数
    
    nullPolicy - 指示在收集过程中是否包含/排除 null 值。
    
    nullEquality - 标志，用于指定每个列表中的 null 条目是否应被视为相等。
    
    nanEquality - 标志，用于指定浮点列中的 NaN 值是否应被视为相等。
  - mergeLists
```
public static GroupByAggregation mergeLists()
```
    合并由多个 CollectListAggregations 产生的部分列表。注意：要合并的部分列表不应包含任何 null 列表元素（但可以包含 null 列表条目）。
  - mergeSets
```
public static GroupByAggregation mergeSets()
```
    合并由多个 CollectSetAggregations 产生的部分集合。每个 null/NaN 值将被视为唯一实例。
  - hostUDF
```
public static GroupByAggregation hostUDF(HostUDFWrapper wrapper)
```
    使用主机端用户定义函数 (UDF) 执行聚合。
    
    参数
    
    wrapper - 原生主机 UDF 实例的包装器。
    
    返回
    
    一个新的 GroupByAggregation 实例
  - mergeSets
```
public static GroupByAggregation mergeSets(NullEquality nullEquality,
                                           NaNEquality nanEquality)
```
    合并由多个 CollectSetAggregations 产生的部分集合。
    
    参数
    
    nullEquality - 标志，用于指定每个列表中的 null 条目是否应被视为相等。
    
    nanEquality - 标志，用于指定浮点列中的 NaN 值是否应被视为相等。
  - mergeM2
```
public static GroupByAggregation mergeM2()
```
    合并由多个 M2Aggregation 实例产生的部分 M2 值。
  - createTDigest
```
public static GroupByAggregation createTDigest(int delta)
```
    根据固定宽度数字输入列计算 t-digest。
    
    参数
    
    delta - 所需精度（桶的数量）。
    
    返回
    
    每个分组的质心列表，其中每个质心都有一个平均值和一个权重。质心的数量将 <= delta。
  - mergeTDigest
```
public static GroupByAggregation mergeTDigest(int delta)
```
    合并 t-digests。
    
    参数
    
    delta - 所需精度（桶的数量）。
    
    返回
    
    每个分组的质心列表，其中每个质心都有一个平均值和一个权重。质心的数量将 <= delta。
  - histogram
```
public static GroupByAggregation histogram()
```
    直方图聚合，计算每行的频率。直方图以列表列的形式给出，其中第一个子列存储输入值的唯一行，第二个子列存储它们对应的频率。
    
    返回
    
    一个包含结构体的列表列，其中每个列表包含对应于输入键的直方图。
  - mergeHistogram
```
public static GroupByAggregation mergeHistogram()
```
    MergeHistogram 聚合，用于合并多个直方图。
    
    返回
    
    一个新的直方图，其中唯一行的频率被求和。

类 GroupByAggregation

方法摘要

继承自类 java.lang.Object 的方法

方法详情

onColumn

hashCode

equals

count

count

sum

product

argMax

argMin

min

max

mean

M2

variance

variance

standardDeviation

standardDeviation

quantile

quantile

median

nunique

nunique

nth

nth

collectList

collectList

collectSet

collectSet

mergeLists

mergeSets

hostUDF

mergeSets

mergeM2

createTDigest

mergeTDigest

histogram

mergeHistogram