in the source DStream