How to explode the dataframe via pyspark

Input:

Output:

Solution:

df = spark.read.format("csv").option("header","True").load("file:///home/cloudera/country.csv")

df.show(truncate=False)

dfp = df.withColumn("country",explode(split("country",",")))

dfp.show()