严肃的西装 · 数据库(一)--通过django创建数据库表 ...· 3 周前 · |
豪气的哑铃 · 通过Jaeger埋点并上报.NET应用数据_ ...· 3 周前 · |
安静的手套 · 4.为模型增加贴图-阿里云开发者社区· 2 周前 · |
飞翔的开心果 · mongoose.connection ...· 2 月前 · |
酒量小的小虾米 · 6. Flying Star Feng ...· 2 月前 · |
酒量小的创口贴 · 实现Java类的热替换 | 追求极致-个人应用日志· 2 月前 · |
仗义的花生 · 海信电视怎么安装软件-智和家问答· 3 月前 · |
卖萌的佛珠 · 广西壮族自治区生态环境厅关于广西德源冶金有限 ...· 4 月前 · |
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
安静的手套 · 4.为模型增加贴图-阿里云开发者社区 2 周前 |
飞翔的开心果 · mongoose.connection is undefined after 'connect' after library updates · Issue #13653 · Automattic/m 2 月前 |
酒量小的创口贴 · 实现Java类的热替换 | 追求极致-个人应用日志 2 月前 |
仗义的花生 · 海信电视怎么安装软件-智和家问答 3 月前 |