将 Pig 输出转换为 JSON 格式
Converting Pig output into JSON Format
我在 Pig 中将以下输出存储在一个变量中:
("Keyword",
{
(data1, data2, data3, data4),
(data1, data2, data3, data4)
}
)
期望 JSON 格式的输出:
{
"keyword": [
{
"val_1": "data1",
"val_2": "data2",
"val_3": "data3",
"val_4": "data4"
},
{
"val_1": "data1",
"val_2": "data2",
"val_3": "data3",
"val_4": "data4"
}
]
}
如有任何帮助,我们将不胜感激。
如果您已经定义了模式,您所要做的就是-
store yourRelation into 'file_location_in_hdfs' using JsonStorage();
这将使用架构、变量名作为 json 标签。
我在 Pig 中将以下输出存储在一个变量中:
("Keyword",
{
(data1, data2, data3, data4),
(data1, data2, data3, data4)
}
)
期望 JSON 格式的输出:
{
"keyword": [
{
"val_1": "data1",
"val_2": "data2",
"val_3": "data3",
"val_4": "data4"
},
{
"val_1": "data1",
"val_2": "data2",
"val_3": "data3",
"val_4": "data4"
}
]
}
如有任何帮助,我们将不胜感激。
如果您已经定义了模式,您所要做的就是-
store yourRelation into 'file_location_in_hdfs' using JsonStorage();
这将使用架构、变量名作为 json 标签。