KnowForgeBolt 后端聚合函数支持
qianmoQ· 更新于 2026-10-02· 阅读 5 分钟· 0 次阅读登录后可跨设备保存划线和私人笔记登录
Bolt 聚合函数支持情况
在 Spark 3.5 的 62 个聚合函数中，Gluten 目前对 Bolt 后端完整支持 54 个函数，部分支持 1 个函数。
聚合函数
| Spark 函数 | Spark 表达式 | 状态 | 限制条件 |
|---|---|---|---|
| any | BoolOr | S | |
| any_value | AnyValue | S | |
| approx_count_distinct | HyperLogLogPlusPlus | S | 仅当子表达式的数据类型为 Boolean、Byte、Short、Int、Long、Float、Double、String、Char、Decimal、Date、Timestamp 或 Binary 之一时才支持。 |
| approx_percentile | ApproximatePercentile | S | |
| array_agg | CollectList | S | |
| avg | Average | S | |
| bit_and | BitAndAgg | S | |
| bit_or | BitOrAgg | S | |
| bit_xor | BitXorAgg | S | |
| bitmap_construct_agg | BitmapConstructAgg | ||
| bitmap_or_agg | BitmapOrAgg | ||
| bool_and | BoolAnd | S | |
| bool_or | BoolOr | S | |
| collect_list | CollectList | S | |
| collect_set | CollectSet | S | |
| corr | Corr | S | |
| count | Count | S | |
| count_if | CountIf | S | |
| count_min_sketch | CountMinSketchAggExpressionBuilder | ||
| covar_pop | CovPopulation | S | |
| covar_samp | CovSample | S | |
| every | BoolAnd | S | |
| first | First | S | |
| first_value | First | S | |
| grouping | Grouping | S | |
| grouping_id | GroupingID | S | |
| histogram_numeric | HistogramNumeric | ||
| hll_sketch_agg | HllSketchAgg | ||
| hll_union_agg | HllUnionAgg | ||
| kurtosis | Kurtosis | S | |
| last | Last | S | |
| last_value | Last | S | |
| max | Max | S | |
| max_by | MaxBy | S | |
| mean | Average | S | |
| median | Median | S | |
| min | Min | S | |
| min_by | MinBy | S | |
| mode | Mode | ||
| percentile | Percentile | S | |
| percentile_approx | ApproximatePercentile | S | |
| regr_avgx | RegrAvgX | S | |
| regr_avgy | RegrAvgY | S | |
| regr_count | RegrCount | S | |
| regr_intercept | RegrIntercept | S | |
| regr_r2 | RegrR2 | S | |
| regr_slope | RegrSlope | S | |
| regr_sxx | RegrSXX | S | |
| regr_sxy | RegrSXY | S | |
| regr_syy | RegrSYY | S | |
| skewness | Skewness | S | |
| some | BoolOr | S | |
| std | StddevSamp | S | |
| stddev | StddevSamp | S | |
| stddev_pop | StddevPop | S | |
| stddev_samp | StddevSamp | S | |
| sum | Sum | S | |
| try_avg | TryAverageExpressionBuilder | S | |
| try_sum | TrySumExpressionBuilder | PS | 部分支持。在某些情况下行为可能与原生 Spark 不同。 |
| var_pop | VariancePop | S | |
| var_samp | VarianceSamp | S | |
| variance | VarianceSamp | S |
评论
登录后参与评论
正在加载评论…