Comment interroger les noms de colonne d'une Étincelle Dataset?

J'ai un val ds: Dataset[Double] (Spark 2.0.0), mais quel est le nom de la double valeur de la colonne qui peut être transmis à apply ou col pour convertir à partir de ce 1 colonnes Dataset à un Column.

InformationsquelleAutor fwc | 2016-09-19
  1. 8

    Le nom de colonne "valeur" comme dans ds.col("value"). Dataset.schema contient cette information: ds.schema.fields.foreach(x => println(x))

    InformationsquelleAutor fwc
  2. 8

    Vous pouvez également utiliser DataFrames'méthode columns, qui renvoie toutes les colonnes dans un Tableau de Chaînes de caractères.

    case class Person(age: Int, height: Int, weight: Int){
  def sum = age + height + weight
}

val df = sc.parallelize(List(Person(1,2,3), Person(4,5,6))).toDF("age", "height", "weight")

df.columns
//res0: Array[String] = Array(age, height, weight)
    InformationsquelleAutor Alberto Bonsanto