|
|
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 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
|
Locked
