Categorize using spark sql Categorize using spark sql database database

Categorize using spark sql


This can be done in SQL as below

SELECT Org, SUM(CASE WHEN class='class1' THEN 1 ELSE O END) As Class1Count,       SUM(CASE WHEN class='class2' THEN 1 ELSE O END) As Class2Count,       SUM(CASE WHEN class='class3' THEN 1 ELSE O END) As Class3Count,       SUM(CASE WHEN class='class4' THEN 1 ELSE O END) As Class4CountFROM tableNameGROUP By Org