aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming/tests.py
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-16950] [PYSPARK] fromOffsets parameter support in KafkaUtils.createDir...Mariusz Strzelecki2016-08-091-9/+3
* [SPARK-15085][STREAMING][KAFKA] Rename streaming-kafka artifactcody koeninger2016-05-111-3/+3
* [SPARK-14936][BUILD][TESTS] FlumePollingStreamSuite is slowXin Ren2016-05-101-1/+1
* [SPARK-13579][BUILD] Stop building the main Spark assembly.Marcelo Vanzin2016-04-041-3/+3
* [SPARK-14073][STREAMING][TEST-MAVEN] Move flume back to SparkShixiong Zhu2016-03-251-3/+165
* [SPARK-13843][STREAMING] Remove streaming-flume, streaming-mqtt, streaming-ze...Shixiong Zhu2016-03-141-263/+3
* [SPARK-13848][SPARK-5185] Update to Py4J 0.9.2 in order to fix classloading i...Josh Rosen2016-03-141-20/+5
* [SPARK-13595][BUILD] Move docker, extras modules into externalSean Owen2016-03-091-1/+1
* [SPARK-7997][CORE] Add rpcEnv.awaitTermination() back to SparkEnvShixiong Zhu2016-02-021-2/+2
* [SPARK-11295][PYSPARK] Add packages to JUnit output for Python testsGábor Lipták2016-01-201-0/+1
* Revert "[SPARK-11295] Add packages to JUnit output for Python tests"Xiangrui Meng2016-01-191-1/+0
* [SPARK-11295] Add packages to JUnit output for Python testsGábor Lipták2016-01-191-0/+1
* [SPARK-12353][STREAMING][PYSPARK] Fix countByValue inconsistent output in Pyt...jerryshao2015-12-281-3/+14
* [SPARK-11713] [PYSPARK] [STREAMING] Initial RDD updateStateByKey for PySparkBryan Cutler2015-12-101-0/+20
* [SPARK-12058][STREAMING][KINESIS][TESTS] fix Kinesis python testsBurak Yavuz2015-12-041-1/+0
* [SPARK-12002][STREAMING][PYSPARK] Fix python direct stream checkpoint recover...jerryshao2015-12-011-0/+49
* [SPARK-12058][HOTFIX] Disable KinesisStreamTestsShixiong Zhu2015-11-301-0/+1
* [SPARK-11935][PYSPARK] Send the Python exceptions in TransformFunction and Tr...Shixiong Zhu2015-11-251-1/+81
* [SPARK-11870][STREAMING][PYSPARK] Rethrow the exceptions in TransformFunction...Shixiong Zhu2015-11-201-0/+16
* [SPARK-11812][PYSPARK] invFunc=None works properly with python's reduceByKeyA...David Tolpin2015-11-191-0/+11
* [SPARK-9065][STREAMING][PYSPARK] Add MessageHandler for Kafka Python APIjerryshao2015-11-171-0/+35
* [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batchShixiong Zhu2015-11-171-5/+4
* [SPARK-6328][PYTHON] Python API for StreamingListenerDaniel Jalova2015-11-161-1/+125
* [SPARK-11706][STREAMING] Fix the bug that Streaming Python tests cannot repor...Shixiong Zhu2015-11-131-10/+20
* [SPARK-11378][STREAMING] make StreamingContext.awaitTerminationOrTimeout retu...Nick Evans2015-11-051-0/+7
* [SPARK-11270][STREAMING] Add improved equality testing for TopicAndPartition ...Nick Evans2015-10-271-0/+10
* [SPARK-7021] Add JUnit output for Python unit testsGábor Lipták2015-10-221-1/+10
* [SPARK-10447][SPARK-3842][PYSPARK] upgrade pyspark to py4j0.9Holden Karau2015-10-201-6/+12
* [SPARK-10615] [PYSPARK] change assertEquals to assertEqualYanbo Liang2015-09-181-1/+1
* [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
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-06 05:46:21 +0000