본문 바로가기
프로그래밍/spark

spark dataframe to map rdd

by 메이슨김 2016. 9. 7.
1
2
3
4
5
6
7
8
9
10
val columnNameList = df.columns
 
val rddMap = df.rdd.map( row =>  { 
    var map = Map[String, Any]()
    for (i <- to columnNameList.length - 1)  {
        map += (columnNameList(i) -> row(i))
    }
    
    map
})
cs


반응형