Функция SUM в PIG

Question

Начав изучать скрипты латинского языка Pig и придерживаться ниже проблемы. Я прошел через подобные вопросы по одной теме без везения! Хотите найти СУММ всех возрастных полей.

DUMP X; 
(22)(19) 
grunt> DESCRIBE X; 
X: {age: int} 

Я попробовал несколько вариантов, таких как:

Y = FOREACH (group X all) GENERATE SUM(X.age); 

Но, получая ниже исключения.

Invalid field projection. Projected field [age] does not exist in schema: group:chararray,X:bag{:tuple(age:int)}. 

Спасибо за ваше время и помощь.

Answer 1

Я думаю, что проекция Y должна работать так, как вы ее написали. Вот маленький пример кода для этого же, и это просто отлично работает для меня.

X = LOAD 'SO/sum_age.txt' USING PigStorage('\t') AS (age:int); 
DESCRIBE X; 
Y = FOREACH (group X all) GENERATE 
    SUM(X.age); 
DESCRIBE Y; 
DUMP Y; 

Таким образом, ваша проблема выглядит странно. Я использовал следующие входные данные:

-bash-4.1$ cat sum_age.txt 
22 
19 

Можете ли вы попробовать те же данные со сценарием, который я вставил здесь?