spark/scalaのJavaRDD [org.apache.spark.sql.Row]のマッピングに使用できる関数を作成する方法は？

Question

val drdd = Seq(("a", 1), ("b", 2), ("a", 3)).toDF("name", "value").toJavaRDD 
drdd.map{ (row: Row) => row.get(0) } 

私は渡された匿名関数は、行=>どれそれが期待されている間org.apache.spark.api.java.function.Function [org.apache.spark.sql.Row ,?]

であるように思えます

<console>:35: error: type mismatch; 
found : org.apache.spark.sql.Row => Any 
required: org.apache.spark.api.java.function.Function[org.apache.spark.sql.Row,?] 
    drdd.map{ (row: Row) => row.get(0) } 
         ^

これらの関数型の違いは何ですか？どのように関数を構成しますか？ありがとう！

Answer 1

例：

drdd.map(new org.apache.spark.api.java.function.Function[Row, String]() { 
    override def call(row: Row): String = row.getString(0) 
})