flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Tumbling Windows with Processing Time
Date Wed, 03 Feb 2016 13:32:55 GMT
There should be 4 windows because there are only 4 distinct keys, if I understand this line
correctly:

 .keyBy(mappedPayload => mappedPayload._1.id.hashcode % parallelism)

> On 02 Feb 2016, at 19:31, yutao sun <yutao.sun.fr@gmail.com> wrote:
> 
>  .keyBy(mappedPayload => mappedPayload._1.id.hashcode % parallelism)


Mime
View raw message