2017-06-13 75 views

回答

2

您可以在一行中使用toSeq方法,然後從Seq[Any]的類型轉換爲Seq[Double](如果你確信所有列的數據類型是雙):

val df = Seq((1.0,2.0),(2.1,2.2)).toDF("A", "B") 
// df: org.apache.spark.sql.DataFrame = [A: double, B: double] 

df.show 
+---+---+ 
| A| B| 
+---+---+ 
|1.0|2.0| 
|2.1|2.2| 
+---+---+ 

df.first.toSeq.asInstanceOf[Seq[Double]] 
// res1: Seq[Double] = WrappedArray(1.0, 2.0) 

如果您有字符串類型列,使用toSeq然後用map與模式匹配的String轉換

val df = Seq((1.0,"2.0"),(2.1,"2.2")).toDF("A", "B") 
// df: org.apache.spark.sql.DataFrame = [A: double, B: string] 

df.first.toSeq.map{ 
    case x: String => x.toDouble 
    case x: Double => x 
} 
// res3: Seq[Double] = ArrayBuffer(1.0, 2.0) 
+0

對不起,它看起來像我的數據框有所有的數字,但字符串格式...有沒有辦法做到這一點?謝謝! –

+0

您可以使用'map'和模式匹配進行一些類型轉換,請參閱更新。 – Psidom

1

如果你有一個dataframedoubles要轉換成的doublesList,那麼就轉換dataframerdd,這將給你RDD[Row]你可以隱蔽的這List

dataframe.rdd.map(_.toSeq.toList) 

您將得到list of doubles