flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Output of KeyBy->TimeWindow->Reduce?
Date Mon, 08 Aug 2016 10:05:50 GMT
Hi,
what does the reduce function do exactly? Something like this?

(a: String, b: String) -> b.toUppercase

If yes, then I would expect a) to be the output you get.

if it is this:

(a: String, b: String) -> a + b.toUppercase

then I would expect this: a,b,cC,d,eE,f,gG,h

Cheers,
Aljoscha

On Sun, 7 Aug 2016 at 17:28 Jon Yeargers <jon.yeargers@cedexis.com> wrote:

> Take the above topology and send the resultant DataStream to .print().
>
> Assume the Reduce function changes a character to it's uppercase
> equivalent.
>
> Assume this whole stream makes it within the span of a single Window.
>
> Send it a stream like a,b,c,d,e,f,g,h,c,e,g.
>
>
> What will be output?
>
> a) a,b,C,d,E,f,G,h
> b) a,b,c,d,e,f,g,h
> c) a,b,c,c,d,e,e,f,g,g,h
> d) something else
>
>
>

Mime
View raw message