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

Reply via email to