Wie bekomme ich Array [Seq [String]] von DataFrame?

Question

Wie geht man DataFramecc in Array[Seq[String]]?

val factors = $(ccCols).split(",") 
val cc = dataset.select(factors.head, factors.tail: _*) 

habe ich versucht auf diese Weise, aber es gibt mir Array[Row]:

cc.rdd.collect() 

Answer 1

Sie das toSeq Funktion des Objekt verwenden müssen:

val a = sc.parallelize(Seq((1,2),(3,4))).toDF("a", "b") 
a.show 
/* 
Output: 
+-+-+ 
|a|b| 
+-+-+ 
|1|2| 
|3|4| 
+-+-+ 
*/ 

a.collect.map(_.toSeq) 
// Output: Array(WrappedArray(1, 2), WrappedArray(3, 4))