> > BTW, I cannot use SparkSQL / case right now because my table has 200 > columns (and I'm on Scala 2.10.3) >
You can still apply the schema programmatically: http://spark.apache.org/docs/latest/sql-programming-guide.html#programmatically-specifying-the-schema
