ai.rapids.cudf

类 Aggregation128Utils

java.lang.Object

ai.rapids.cudf.Aggregation128Utils

public class Aggregation128Utils
extends Object

用于在聚合期间分解和重新组装 128 位值的实用方法，以支持基于哈希的聚合并检测溢出。

构造方法摘要

构造方法

构造方法和描述
Aggregation128Utils()

方法摘要

修饰符和类型	方法和描述
static Table	combineInt64SumChunks(Table chunks, DType type) 从一个由四个 64 位整数列组成的表中重新组装一个 128 位值的列，并检查是否溢出。
static ColumnVector	extractInt32Chunk(ColumnView col, DType outType, int chunkIdx) 从 128 位值中提取一个 32 位块。

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造方法详情

Aggregation128Utils

public Aggregation128Utils()

方法详情

extractInt32Chunk

public static ColumnVector extractInt32Chunk(ColumnView col,
                                             DType outType,
                                             int chunkIdx)

从 128 位值中提取一个 32 位块。

参数

col - 128 位值的列（例如：DECIMAL128）

outType - 用于输出列的整数类型（例如：UINT32 或 INT32）

chunkIdx - 要提取的 32 位块的索引，其中 0 是最低有效块，3 是最高有效块

返回

包含输入列值的指定 32 位块的列。空输入行将导致相应的空输出行。

combineInt64SumChunks

public static Table combineInt64SumChunks(Table chunks,
                                          DType type)

从一个由四个 64 位整数列组成的表中重新组装一个 128 位值的列，并检查是否溢出。通过将 64 位值重叠 32 位来重建 128 位值。最低有效 64 位值的最低有效 32 位直接用作最终 128 位值的最低有效 32 位，剩余的 32 位被添加到下一个最高有效 64 位值。该和的低 32 位成为最终 128 位值中的下一个最高有效 32 位，剩余的 32 位被添加到下一个最高有效 64 位输入值，依此类推。

参数

chunks - 由四个 64 位整数列组成的表，列按从最低有效到最高有效的顺序排列。最后一列必须是 INT64 类型。

type - 用于结果 128 位值列的类型

返回

包含布尔列和所需类型的 128 位值列的表。如果该行的值在重新组装时检测到溢出，布尔值将为 true。空输入行将导致相应的空输出行。