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 vote322 views3 answers
`Got permission denied while trying to connect to the Docker daemon socket at unix:///var/run/docker.sock: Post http://%2Fvar%2Frun%2Fdocker.sock/v1.24/images/create?fromImage=mysql&tag=latest: dial unix /var/run/docker.sock: connect: permission
Go
0 vote359 views1 answer
Golang pq timestamp
Go
0 vote326 views1 answer
Golang time.Add with variables
Go
0 vote363 views1 answer
Union in go
Go
0 vote330 views1 answer
Golang writefile example
Go
0 vote412 views1 answer
Create json in go
Go
0 vote349 views1 answer
Go ipfs
Go
3 votes351 views1 answer
Base64 encode golang
Go
1 vote349 views1 answer
Go imports
Go
0 vote354 views1 answer
Google domain price
Go