code aggregates transactions.csv in Spark