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 vote333 views1 answer
Golang read large file
Go
0 vote343 views1 answer
Aws s3 get file size
Go
0 vote332 views1 answer
Invalid set index godot
Go
0 vote259 views2 answers
Go slices
Go
27 votes409 views4 answers
Updates were rejected because the tip of your current branch is behind
Go
0 vote311 views2 answers
Mongo restore collections
Go
208 votes424 views4 answers
Docs .google com
Go
0 vote305 views1 answer
Which gopros have the same form factor and port alignment
Go
9 votes354 views2 answers
Go create list length
Go
10 votes351 views2 answers
Golang compiler
Go