【问题标题】:Load JSON data enclosed in square brackets using Elephant Bird JsonLoader in Apache PIG使用 Apache PIG 中的 Elephant Bird JsonLoader 加载方括号中的 JSON 数据
【发布时间】:2017-06-26 13:56:14
【问题描述】:

如果记录采用这种格式,我可以使用 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;

请指教!在此先感谢:)

【问题讨论】:

    标签: json hadoop apache-pig user-defined-functions elephantbird


    【解决方案1】:

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

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2021-09-19
      相关资源
      最近更新 更多