added the test code for spark streaming