US9953003B2 - Systems and Methods for in-Line Stream Processing of Distributed Dataflow Based Computations