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/