json - 使用Apache PIG中的Elephant Bird JsonLoader加载方括号中的JSON数据

Question

如果记录采用以下格式，则可以使用Elephantbird JsonLoader加载数据:

{"disknum":36,"disksum":136.401,"disk_rate":1872.0,"disk_lnum": 13}

但是实际数据采用以下格式:(用方括号括起来)

[{"disknum":36,"disksum":136.401,"disk_rate":1872.0,"disk_lnum": 13}]

当我尝试解析它时，它不会抛出错误，也不会提供任何有用的输出。显示成功!读取0条记录，写入0条记录。

请提出如何使用方括号处理数据。

以下是非方括号记录的语法:

register '/home/data/Desktop/elephantbird/elephant-bird-core-4.1.jar';
register '/home/gopal/Desktop/elephantbird/elephant-bird-hadoop-compat-4.1.jar';
register '/home/gopal/Desktop/elephantbird/elephant-bird-pig-4.1.jar';
register '/home/gopal/Desktop/elephantbird/json-simple-1.1.jar';
a = LOAD '/pig/tc1.log' USING com.twitter.elephantbird.pig.load.JsonLoader() as (json:map[]);
b = FOREACH a GENERATE flatten(json#'node_disk_lnum_1') AS node_disk_lnum_1, flatten(json#'node_disk_xfers_in_rate_sum') AS node_disk_xfers_in_rate_sum, flatten(json#'node_disk_bytes_in_rate_22') AS node_disk_bytes_in_rate_22,  flatten(json#'node_disk_lnum_7') AS node_disk_lnum_7;
dump b;

请指教!提前致谢 :)

Answer 1

我认为这可能会有所帮助:查看解决方案，它非常接近。
Json parse with elephantbird in Pig

您需要为json提供一个根名。