Merging pySpark to streaming

As part of resolving the merge conflicts, I have decided to not give Python RDDs support for checkpointing as I do not have a detailed understanding of Python RDDs work. Also, it may require extending the python API to support checkpointing. So this has been deferred for future.