datafu-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Eyal Allweil (JIRA)" <>
Subject [jira] [Commented] (DATAFU-116) Make SetIntersect and SetDifference implement Accumulator
Date Tue, 08 Mar 2016 18:18:40 GMT


Eyal Allweil commented on DATAFU-116:

As far as I can tell, when the accumulator is used, Pig passes _pig.accumulative.batchsize_
tuples from each bag until all the tuples are exhausted. I think an implementation that iterates
over the bags and only keeps some of the tuples in between batches is possible - hopefully
very few, but the worst case is all of them, which is no worse than the current implementation.

I'm assuming Pig passes batches in this way based on the code in [POPackage|]
and from looking through all the documentation I could find on accumulators. If I'm wrong
it does mean that an accumulator implementation isn't worthwhile.

> Make SetIntersect and SetDifference implement Accumulator
> ---------------------------------------------------------
>                 Key: DATAFU-116
>                 URL:
>             Project: DataFu
>          Issue Type: Improvement
>    Affects Versions: 1.3.0
>            Reporter: Eyal Allweil
> SetIntersect and SetDifference accept only sorted bags, and the output is always smaller
than the inputs. Therefore an accumulator implementation should be possible and it will improve
memory usage (somewhat) and allow Pig to optimize loops with these operations better.

This message was sent by Atlassian JIRA

View raw message