Consider the below the code snippet.

Schema of the dataset used is EmployeeID, Skillset.

empRdd = sc.parallelize([ (1001,'BigData'), (1002,'Java'), (1003,'Sql') ]) # Line 1

result = empRdd.collectAsMap() # Line2

print(result) # Line 3

Predict the correct output.

To get all Infosys Certified PySpark Professional Exam questions Join Telegram Group https://rebrand.ly/lex-telegram-236dee