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
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
>
>
>
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
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),