Ekaterina Gonina

Right now we only handle filterValues, mapValues and flatMapValues operations between a join and a dependent store (see #557). Add support for merging another producer between join/store like: ``` val...

.optionMap(..).optionMap(..) push to Spout

4

Right now when we have source.optionMap(..).optionMap(..).sumByKey(store), the first option map gets pushed up to the spout (Tail-FlatMap-Source node), but the second one gets tacked onto a flatMap (Tail-FlatMap node) with...

For offline jobs that join against a dependent store (i.e. the store depends on the result of the join), we need support for handling diamond cases in the job dag....