Блог

Я пытаюсь загрузить файлы json, и когда я загружаю определенное поле, pig, похоже, распознает его как строку или пакет.

Элемент Json «программа» в файле может быть:

 "program":"open"
 

Или :

 "program": ["jump","jump"]
 

Я использую следующий код для загрузки файла :

 rel = LOAD '$filePath' USING com.twitter.elephantbird.pig.load.JsonLoader('-nestedLoad') AS (json:map []);

flat = FOREACH rel GENERATE
(chararray)json#'program' AS program;
 

Но когда я пытаюсь отфильтровать, скрипт выдает ошибку (не удается отфильтровать с помощью пакета).

 open = FILTER flat BY program MATCHES 'open';
 

Если у кого-нибудь есть идея ?

Заранее спасибо!