aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming/tests.py
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-8389] [STREAMING] [PYSPARK] Expose KafkaRDDs offsetRange in Pythonjerryshao2015-07-091-0/+64
* [SPARK-8378] [STREAMING] Add the Python API for Flumezsxwing2015-07-011-2/+177
* [SPARK-8583] [SPARK-5482] [BUILD] Refactor python/run-tests to integrate with...Josh Rosen2015-06-271-0/+16
* [SPARK-2808] [STREAMING] [KAFKA] cleanup tests fromcody koeninger2015-06-071-5/+0
* [SPARK-7497] [PYSPARK] [STREAMING] fix streaming flaky testsDavies Liu2015-06-011-8/+8
* [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2cody koeninger2015-05-011-3/+5
* [SPARK-5946] [STREAMING] Add Python API for direct Kafka streamjerryshao2015-04-271-7/+77
* [SPARK-6953] [PySpark] speed up python testsReynold Xin2015-04-211-24/+39
* [SPARK-6949] [SQL] [PySpark] Support Date/Timestamp in Column expressionDavies Liu2015-04-211-5/+1
* [SPARK-4897] [PySpark] Python 3 supportDavies Liu2015-04-161-19/+20
* [SPARK-6211][Streaming] Add Python Kafka API unit testjerryshao2015-04-091-1/+42
* [SPARK-4969][STREAMING][PYTHON] Add binaryRecords to streamingfreeman2015-02-031-0/+15
* [SPARK-2377] Python API for Streaminggiwa2014-10-121-0/+545