Hi, 

Could you help me if I want to do aggregations of two joined streams such as
AVG 


FirstStream.join(SecondStream)
                                .where(new FirstKeySelector())
                                .equalTo(new SecondKeySelector())
                                
.window(TumblingEventTimeWindows.of(Time.milliseconds(10000)))
                                .apply(joinStreamFunc).print();
// here I need to add avg( filed 1)


Regards. 



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reply via email to