twitter / summingbird

Streaming MapReduce with Scalding and Storm
https://twitter.com/summingbird
Apache License 2.0
2.14k stars 267 forks source link

Refactor Memory platform code. #666

Closed pankajroark closed 8 years ago

pankajroark commented 8 years ago

The way AlsoProducer code is handled currently is side-effecty, executes left producer of an also produder while planning, leading to lack of control over execution of different parts. Refactoring that to be more functional to be able to plan all of it first and then execute later.