Qtr No. 213, New Town Yehlanka
Indore 454775, India
Shane works on a data analytics project and needs to perform analysis on employee data (Employee.csv file).
Schema: EmployeeID, EmployeeName, Age, Salary, Department.
Which of the below code snippet can be used to sort the employees based on the department in descending order?
logsRDD = sc.textFile("/dataset/Employee")
FieldsRDD = logsRDD.map(lambda var1: var1.split(","))
logdata= FieldsRDD.map(lambda var1: (var1[4], [var1[0],var1[1],var1[2], var1[3]]))
sortdata= logdata.sortByKey(ascending=False,keyfunc=lambda k: k)
logsRDD = sc.textFile("/dataset/Employee")
FieldsRDD = logsRDD.map(lambda var1: var1.split(","))
logdata= FieldsRDD.map(lambda var1: (var1[4], [var1[0],var1[1],var1[2], var1[3]]))
sortdata= logdata.sortByKey(ascending=True,keyfunc=lambda k: k)
logsRDD = sc.textFile("/dataset/Employee")
FieldsRDD = logsRDD.map(lambda var1: var1.split(","))
logdata= FieldsRDD.map(lambda var1: (var1[4], [var1[0],var1[1],var1[2], var1[3]]))
sortdata= logdata.sort(ascending=True,keyfunc=lambda k: k)
logsRDD = sc.textFile("/dataset/Employee")
FieldsRDD = logsRDD.map(lambda var1: var1.split(","))
logdata= FieldsRDD.map(lambda var1: [(var1[0], var1[1],var1[2],var1[3], var1[4]]))
sortdata= logdata.sort(ascending=False,keyfunc=lambda k: k)
To get all Infosys Certified PySpark Professional Exam questions Join Telegram Group https://rebrand.ly/lex-telegram-236dee
