initial commit for pySparkStreaming
Merge remote-tracking branch 'upstream/master'
comment PythonDStream.PairwiseDStream
modify dstream.py to fix indent error
added reducedByKey not working yet
implementing transform function in Python
modified the code base on comment in https://github.com/tdas/spark/pull/10
add coment for hack why PYSPARK_PYTHON is needed in spark-submit
add coment for hack why PYSPARK_PYTHON is needed in spark-submit
remove not implemented DStream functions in python
revert pom.xml
revert streaming pom.xml
revert streaming/pom.xml
sorted the import following Spark coding convention
add empty line
remove unused import in python
initial commit for socketTextStream
fied input of socketTextDStream
fixed for socketTextStream
added doctest for pyspark.streaming.duration