Pysaprk explode

>>> df = spark.createDataFrame([(1, "A", [1,2,3]), (2, "B", [3,5])],["col1", "col2", "col3"])
>>> from pyspark.sql.functions import explode
>>> df.withColumn("col3", explode(df.col3)).show()
+----+----+----+
|col1|col2|col3|
+----+----+----+
|   1|   A|   1|
|   1|   A|   2|
|   1|   A|   3|
|   2|   B|   3|
|   2|   B|   5|
+----+----+----+

Source: stackoverflow.com

Similar codes

0 vote224 views1 answer
Golang convert from ISO 8601 to milliseconds
Go
0 vote273 views1 answer
Import cryptocurrency price data into google sheets
Go
0 vote241 views1 answer
Go relational operators
Go
0 vote237 views1 answer
Golang overwrite file
Go
0 vote260 views1 answer
Read contents of a file and convert to list + go
Go
4 votes230 views1 answer
Ubuntu mongodb db list
Go
0 vote263 views1 answer
Golang time comparision
Go
3 votes240 views1 answer
Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.20.1:test (default-test) on project upload
Go
0 vote226 views1 answer
Go Pause execution for several seconds
Go
1 vote244 views2 answers
Random number golang
Go