Base2の対数をSparkのRDDに適用するには？

Question

私のRDDにlog2を適用するためにこれを行う適切な方法は何ですか？これを手助けする機能はありますか？

Answer 1

RDD：

import org.apache.commons.math.util.MathUtils 

val rdd: RDD[Double] = ??? 
rdd.map(x => MathUtils.log(2.0, x)) 

DATAFRAME：

import org.apache.spark.sql.functions.log2 

rdd.toDF("value").select(log2("value"))