CentOS 6에서 SparkSQL 프로그래밍
$ bin/spark-shell scala> case class Trans(accNo:String, tranAmount:Double)defined class Trans scala> def toTrans = (trans:Seq[String]) => Trans(trans(0),trans(1).trim.toDouble)toTrans: Seq[String] => Trans scala> val acTransList = Array("SB10001,1000","SB10002,1200","SB10003,8000","SB10004,400","SB10005,300","SB10006,10000","SB10007,500","SB10008,56","SB10009,30","CR10010,7000","SB10002,-10")acT..
2017.08.08