vector_sum

聚合函数:返回组中浮向量元素的和。 所有向量必须具有相同的维度。

有关相应的 Databricks SQL 函数,请参阅 vector_sum 聚合函数

Syntax

from pyspark.sql import functions as dbf

dbf.vector_sum(col=<col>)

Parameters

参数 类型 说明
col pyspark.sql.Column 或列名 输入向量列。

Returns

pyspark.sql.Column:以元素方式求和向量作为浮点数组。

示例

from pyspark.sql import functions as dbf
from pyspark.sql.types import ArrayType, FloatType, StructType, StructField

schema = StructType([StructField('v', ArrayType(FloatType()))])
df = spark.createDataFrame([([1.0, 2.0],), ([3.0, 4.0],)], schema)
df.select(dbf.vector_sum('v')).first()[0]
# [4.0, 6.0]