Traian questions

Traian answers

• How to aggregate a Spark data frame to get a sparse vector using Scala?
• using DataSet.repartition in Spark 2 - several tasks handle more than one partition
• SQL query in Spark/scala Size exceeds Integer.MAX_VALUE
• Spark aggregate on multiple columns within partition without shuffle
• Exception in thread "main" java.lang.NoSuchMethodError: scala.Predef$.refArrayOps([Ljava/lang/Object;)Lscala/collection/mutable/ArrayOps