kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eno Thereska <eno.there...@gmail.com>
Subject Re: doing > 1 'parallel' operation on a stream
Date Mon, 12 Dec 2016 15:51:13 GMT
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.yeargers@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?


Mime
View raw message