[PIG-5224] Extra foreach from ColumnPrune preventing Accumulator usage

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.17.0
• Hadoop Flags: Reviewed
• Assignee: Koji Noguchi
• Reporter: Koji Noguchi
• Created: 13/Apr/17 20:58
• Updated: 21/Jun/17 09:15
• Resolved: 25/May/17 20:13

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.