Ask about aggeragtion on joined streams

[Rad Rad]

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/