Re: doing > 1 'parallel' operation on a stream

2016-12-12 Thread Eno Thereska
Hi there, Just pass your stream twice to the aggregator. No need to duplicate it or copy it etc. Eg. stream2 = stream1.aggregate(...) stream3 = stream1.aggregate(/* some different aggregation */) Thanks Eno > On 12 Dec 2016, at 11:09, Jon Yeargers wrote: > > If I want to aggregate a stream t

doing > 1 'parallel' operation on a stream

2016-12-12 Thread Jon Yeargers
If I want to aggregate a stream twice using different windows do I need to split / copy / duplicate the source stream somehow? Or will this be handled without my interference?