AW: max aggregator dosen't work as expected

2016-08-08 Thread Claudia Wegmann
he.org] Gesendet: Montag, 8. August 2016 15:52 An: user@flink.apache.org Betreff: Re: max aggregator dosen't work as expected I have to admit that the difference between the two methods is subtle, and in my opinion it doesn't make much sense to have the two variants. - max() returns a tuple with t

Re: max aggregator dosen't work as expected

2016-08-08 Thread Robert Metzger
4 data sets > are printed. Sorry J > > But question 1.) still remains. > > > > *Von:* Claudia Wegmann [mailto:c.wegm...@kasasi.de] > *Gesendet:* Montag, 8. August 2016 14:27 > *An:* user@flink.apache.org > *Betreff:* max aggregator dosen't work as expected > > >

AW: max aggregator dosen't work as expected

2016-08-08 Thread Claudia Wegmann
An: user@flink.apache.org Betreff: max aggregator dosen't work as expected Hey, I have some questions to aggregate functions such as max or min. Take the following example: //create Stream with event time where Data contains an ID, a timestamp and a temperature value DataStream oneStream

max aggregator dosen't work as expected

2016-08-08 Thread Claudia Wegmann
Hey, I have some questions to aggregate functions such as max or min. Take the following example: //create Stream with event time where Data contains an ID, a timestamp and a temperature value DataStream oneStream = env.fromElements( new Data(123, new Date(116, 8,8,11,11,11), 5),