I was trying to debugging and I accidentally commented out the groupBy for
debugging purpose and I found interesting output. So thought of mailing the
user group to understand things better.
The following statements instead of counting the words like (
[test,2],[healthcare, 3] ) , it does global grouping with the global key in
this case ([$REDIS-MAP-STATE-GLOBAL, 100]). The count per word is not done. I
am not sure why.
stream
.each(new Fields("tweet"), new Split() ,new Fields("words"))
//.groupBy(new Fields("words"))
.persistentAggregate(redisStateFactory, new Fields("words"),new CustomCount(),
new Fields("invindex"))
.newValuesStream()
.partitionPersist(redisPublisher, new RedisPublisher("WordCount"));
if I uncomment groupby then it all works ok. So, does the groupby replaces the
gloablkey and produces key per word ?
Regards,
Madhu Jahagirdar
________________________________
The information contained in this message may be confidential and legally
protected under applicable law. The message is intended solely for the
addressee(s). If you are not the intended recipient, you are hereby notified
that any use, forwarding, dissemination, or reproduction of this message is
strictly prohibited and may be unlawful. If you are not the intended recipient,
please contact the sender by return e-mail and destroy all copies of the
original message.
