aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming/dstream.py
Commit message (Expand)AuthorAgeFilesLines
* [MINOR] Fix Typos 'an -> a'Zheng RuiFeng2016-06-061-2/+2
* [MINOR] Fix Typos 'a -> an'Zheng RuiFeng2016-05-261-1/+1
* [SPARK-9819][STREAMING][DOCUMENTATION] Clarify doc for invReduceFunc in incre...François Garillot2016-05-031-1/+3
* [SPARK-13339][DOCS] Clarify commutative / associative operator requirements f...Sean Owen2016-02-191-2/+2
* [SPARK-12353][STREAMING][PYSPARK] Fix countByValue inconsistent output in Pyt...jerryshao2015-12-281-2/+2
* [SPARK-12091] [PYSPARK] Deprecate the JAVA-specific deserialized storage levelsgatorsmile2015-12-181-2/+2
* [SPARK-11904][PYSPARK] reduceByKeyAndWindow does not require checkpointing wh...David Tolpin2015-12-161-22/+23
* [SPARK-11713] [PYSPARK] [STREAMING] Initial RDD updateStateByKey for PySparkBryan Cutler2015-12-101-2/+11
* [SPARK-11812][PYSPARK] invFunc=None works properly with python's reduceByKeyA...David Tolpin2015-11-191-3/+3
* [SPARK-10122] [PYSPARK] [STREAMING] Fix getOffsetRanges bug in PySpark-Stream...jerryshao2015-08-211-1/+4
* [SPARK-8444] [STREAMING] Adding Python streaming example for queueStreamBryan Cutler2015-06-191-1/+1
* [SPARK-4897] [PySpark] Python 3 supportDavies Liu2015-04-161-23/+28
* [SPARK-5785] [PySpark] narrow dependency for cogroup/join in PySparkDavies Liu2015-02-171-1/+1
* [SPARK-3325][Streaming] Add a parameter to the method print in class DStreamYadong Qi2015-01-021-5/+7
* [SPARK-3952] [Streaming] [PySpark] add Python examples in Streaming Programmi...Davies Liu2014-10-181-3/+5
* [SPARK-2377] Python API for Streaminggiwa2014-10-121-0/+621