support accumulative mode when nested non-blocking relations are present as
input
---------------------------------------------------------------------------------
Key: PIG-1980
URL: https://issues.apache.org/jira/browse/PIG-1980
Project: Pig
Issue Type: Improvement
Affects Versions: 0.9.0
Reporter: Thejas M Nair
Fix For: 0.10
In queries such as following, where the udf in nested foreach is getting input
from a non-blocking relation (eg, filter, limit), it should be possible to use
the accumulative mode.
{code}
a = load 't.txt' as (f1:int,f2:int);
b = group a by f1;
c = foreach b { fa = filter a by f2 > 1; generate COUNT(fa) ; }
explain c;
{code}
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira