Tag Archives: mapreduce

Scalding merge, concatenation and joins of pipes

I recently built a scalding job that ran everyday collection a set of ids with timestamps to determine the newest and oldest occurrence of a set, whilst merging that with previously aggregated set. A very simple task, involving simple mapping … Continue reading

Posted in Scala, Uncategorized | Tagged , , , | Leave a comment