深沉的松鼠 · [Python] ...· 昨天 · |
有胆有识的椰子 · Pandas ...· 昨天 · |
怕老婆的钱包 · 解析csv文件,读取百万级数据_51CTO博 ...· 昨天 · |
坏坏的羽毛球 · 数据分析利器 pandas ...· 昨天 · |
火爆的香瓜 · 建议收藏!Python ...· 昨天 · |
想表白的荒野 · 新华社长篇通讯追记黄文秀:用生命坚守初心和使 ...· 2 月前 · |
另类的眼镜 · 广东英利光伏电力开发有限公司 - ...· 3 月前 · |
茫然的键盘 · 联想电脑摄像头灰色带锁怎么办-摄像头打开了但 ...· 4 月前 · |
深情的山寨机 · 全国GDP十强城市排名洗牌 ...· 8 月前 · |
from pyspark.sql import Window, DataFrame
from pyspark.sql.types import *
from pyspark.sql.types import StructType
from pyspark.sql import functions as F
schema = StructType([
StructField("data", StructType([
StructField("indicatr", StructType([
StructField("indicatr", StructType([
StructField("id", StringType())
]))]))]))])
df = spark.read.json("pathtofile/test.json", multiLine=True)
df.show()
df2 = df.withColumn("json", F.col("data").cast("string"))
df3=df2.select(F.col("json"))
df3.collect()
df4 =df3.select(F.from_json(F.col("json"), schema).alias("name"))
df4.show()
我得到以下结果:
|name|
+----+
|null|
谁知道如何解决这个问题
企业邮箱发送邮件时,若出现投递失败产生退信,内容提示包含如下: the mta server of * reply:550 failed to meet SPF requirements 或者 the mta server of 163.com — 163mx01.mxmail.netease.com(220.181.14.141) reply:550 MI:SPF mx14,QMCowECpA0qTiftVaeB3Cg—.872S2 1442548128 http://mail.163.com/help
303476