aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming/tests.py
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-10168] [STREAMING] Fix the issue that maven publishes wrong artifact jarszsxwing2015-08-241-21/+26
* [SPARK-10142] [STREAMING] Made python checkpoint recovery handle non-local ch...Tathagata Das2015-08-231-7/+36
* [SPARK-10122] [PYSPARK] [STREAMING] Fix getOffsetRanges bug in PySpark-Stream...jerryshao2015-08-211-1/+3
* [SPARK-9572] [STREAMING] [PYSPARK] Added StreamingContext.getActiveOrCreate()...Tathagata Das2015-08-111-11/+122
* [SPARK-9640] [STREAMING] [TEST] Do not run Python Kinesis tests when the Kine...Tathagata Das2015-08-101-12/+44
* [SPARK-5155] [PYSPARK] [STREAMING] Mqtt streaming support in PythonPrabeesh K2015-08-101-2/+104
* [SPARK-8564] [STREAMING] Add the Python API for Kinesiszsxwing2015-07-311-1/+85
* [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