Why dont you directly use DStream created as output of windowing process? Any reason Regards Mayur
Mayur Rustagi Ph: +1 (760) 203 3257 http://www.sigmoidanalytics.com @mayur_rustagi <https://twitter.com/mayur_rustagi> On Thu, Aug 21, 2014 at 8:38 PM, Josh J <joshjd...@gmail.com> wrote: > Hi, > > I would like to have a sliding window dstream perform a streaming > computation and store these results. Once these results are stored, I then > would like to process the results. Though I must wait until the final > computation done for all tuples in the sliding window, before I begin the > new DStream. How can I accomplish this with spark? > > Sincerely, > Josh >
