> >
> > 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 wrote:
> >>
> >> .keyBy(mappedPayload => mappedPayload._1.id.hashcode % parallelism)
> >
>
>
gs,
> Stephan
>
>
> On Tue, Feb 2, 2016 at 7:31 PM, yutao sun wrote:
>
>> Hi Flink users,
>>
>> I have a question about Tumbling Windows using Processing Time at Flink
>> ver 0.10.1 :
>>
>> In fact, I want to measure the throughput of my applicati
Hi Flink users,
I have a question about Tumbling Windows using Processing Time at Flink ver
0.10.1 :
In fact, I want to measure the throughput of my application, the idea is at
the last operator, by using a Tumbling processing Time windows with a size
of 1 second, I count the message received.
T
