Python UDFs

[Stefan Panayotov]

Hi,
 
I have defined a UDF in Scala like this:
 
import org.apache.spark.mllib.linalg.Vector
import org.apache.spark.mllib.stat.{MultivariateStatisticalSummary, Statistics}
import org.apache.spark.mllib.linalg.DenseVector
 
val determineVector = udf((a: Double, b: Double) => {
    val data: Array[Double] = Array(a,b)
    val dv = new DenseVector(data)
    dv
  })

How can I write the corresponding function in Pyhton/Pyspark?
 
Thanks for your help


Stefan Panayotov, PhD 
Home: 610-355-0919 
Cell: 610-517-5586 
email: spanayo...@msn.com 
spanayo...@outlook.com 
spanayo...@comcast.net