Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
12-14-2022 10:10 PM
You can build your schema like this...
schema = spark.read.json(capture_tmp.rdd.map(lambda row: row.columnNamewithValue)).schema
Then, df.withColumn('new_col', from_json(col('yourcolumnname'), schema))
Uma Mahesh D
