我在 json 中有以下数据结构,我试图使用 AWS Glue 进入数据框:
{
"out": [
{
"attr": [ "a1", "a2", "a3" ],
"val": [ 1, 2, 3 ],
"text": "test1"
},
{
"attr": [ "a4", "a5", "a6" ],
"val": [ 4, 5, 6 ],
"text": "test2"
}
],
"ids": [
"id1",
"id2"
]
}
“ids”字段是“out”中条目的平行数组。我一直在努力获得以下信息:
id text attr val
-- ---- ---- ---
id1 test1 [a1, a2, a3] [1,2,3]
id2 test2 [a4, a5, a6] [4,5,6]
我已经能够将 id 和“out”的内容分成两个数据框,但我找不到水平连接它们的方法。
使用
spark_context = SparkContext.getOrCreate()
glue_context = GlueContext(spark_context)
spark = glue_context.spark_session
print("Loading data...")
df = spark.read.json(<location>)
df.printSchema()
我得到以下架构:
root
|-- out: array (nullable = true)
| |-- element: struct (containsNull = true)
| | |-- attr: array (nullable = true)
| | | |-- element: string (containsNull = true)
| | |-- val: array (nullable = true)
| | | |-- element: double (containsNull = true)
| | |-- text: string (nullable = true)
|-- id: array (nullable = true)
| |-- element: string (containsNull = true)