【发布时间】:2020-10-04 04:05:33
【问题描述】:
我正在尝试规范化用户项目矩阵,但我想使用这个公式:
(df.values-df.values.min())/(df.values.max()-df.values.min())
【问题讨论】:
标签: pyspark normalization standardized
我正在尝试规范化用户项目矩阵,但我想使用这个公式:
(df.values-df.values.min())/(df.values.max()-df.values.min())
【问题讨论】:
标签: pyspark normalization standardized
您可以创建一个函数并在其他函数中同样重用---
def compute_function(df):
_count = (df.values-df.values.min())/(df.values.max()-df.values.min())
df = df.withColumn("new_column", F.lit(_count))
return df
df = compute_function(df)
df.show()
【讨论】: