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 <jon.yearg...@cedexis.com> wrote: > > 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?
