у меня ниже данные
primary,first,second
1,393440.09,354096.08
1,4410533.33,3969479.99
1,-4803973.41,-4323576.07
Я должен агрегировать и суммировать первый и второй столбец. Ниже приведен сценарий, который я выполняю
data_load= load <filelocation> using org.apache.pig.piggybank.storage.CSVExcelStorage(',', 'NO_MULTILINE', 'NOCHANGE', 'SKIP_INPUT_HEADER') As (primary:double, first:double,second:double)
dataAgrr = group data_load by primary;
sumData = FOREACH dataAgrr GENERATE
group as data,
SUM(data_load.first) as first,
SUM(data_load.second) as second,
SUM(data_load.primary) as primary;
После выполнения ниже выводится вывод:
(1.0,0.009999999951105565,-5.820766091346741E-11,3.0)
Но когда мы вручную добавляем второй столбец (354096,08, 3969479,99, -4323576,07), получается 0.