Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
Reviewed
Description
A = load 'input' as (id:int, fruit); B = foreach A generate id; -- to enable columnprune C = group B by id; D = foreach C { o = order B by id; generate org.apache.pig.test.utils.AccumulatorBagCount(o); } STORE D into ...
Pig fails to use Accumulator interface for this UDF.