【发布时间】:2020-01-15 13:17:21
【问题描述】:
val columnsToSum = privacyColumnsName.reduce((left, right) => (left)+ (right))
然后:
privacy = privacy.withColumn("Result",when(columnsToSum === privacyColumnsName.size,1).otherwise(0))
我明白了:
错误:(111, 63) value === is not a member of String privacy = privacy.withColumn("Result",when(columnsToSum === privacyColumnsName.size,1).otherwise(0))
我用== 和equals 试过,同样的错误被抛出。
【问题讨论】:
-
privacyColumnsName 的数据类型是什么?
标签: scala dataframe apache-spark functional-programming apache-spark-sql