Added function to test streaming applications
Do reduce before updateStateByKey