假設csv檔案是這種格式：

user, topic, hits
om,  scala, 120
daniel, spark, 80
3754978, spark, 1

我們可以使用第一行來定義一個header class：

class SimpleCSVHeader(header:Array[String]) 
extends Serializable{
    val index = header.zipWithIndex.toMap
    def apply(array:Array[String], 
    key:String)
    :String =array(index
 
(key))
}

然後我們可以利用這個header class 來得到資料：

val csv = sc.textFile("file.csv") // original file 
val data = csv.map(line => line.split(",").map(elem=>elem.trim)) //lines ion rows
val header = new SimpleCSVHeader(data.take(1)(0))
// 取出第一行來建立header
val rows = data.filter(line => header(line,"user") != "user"
 
) // 去掉header
val users = rows.map(row => header(row,"user"))
val usersByHits = rows.map(row => header(row,"user") -> header(row,"hits").toInt)