aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-12091] [PYSPARK] Deprecate the JAVA-specific deserialized storage levelsgatorsmile2015-12-185-7/+7
* [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-102-2/+31
* [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-012-6/+56
* [SPARK-12058][HOTFIX] Disable KinesisStreamTestsShixiong Zhu2015-11-301-0/+1
* [SPARK-11935][PYSPARK] Send the Python exceptions in TransformFunction and Tr...Shixiong Zhu2015-11-252-10/+101
* [SPARK-11870][STREAMING][PYSPARK] Rethrow the exceptions in TransformFunction...Shixiong Zhu2015-11-202-0/+19
* [SPARK-11812][PYSPARK] invFunc=None works properly with python's reduceByKeyA...David Tolpin2015-11-192-3/+14
* [SPARK-9065][STREAMING][PYSPARK] Add MessageHandler for Kafka Python APIjerryshao2015-11-172-12/+134
* [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-164-2/+210
* [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-052-1/+8
* [SPARK-11270][STREAMING] Add improved equality testing for TopicAndPartition ...Nick Evans2015-10-272-0/+20
* [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-206-56/+24
* [DOC] [PYSPARK] [MLLIB] Added newlines to docstrings to fix parameter formattingnoelsmith2015-09-212-0/+3
* [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-232-16/+49
* [SPARK-10122] [PYSPARK] [STREAMING] Fix getOffsetRanges bug in PySpark-Stream...jerryshao2015-08-212-2/+7
* [SPARK-9812] [STREAMING] Fix Python 3 compatibility issue in PySpark Streamin...zsxwing2015-08-193-3/+9
* [SPARK-9828] [PYSPARK] Mutable values should not be default argumentsMechCoder2015-08-141-3/+9
* [SPARK-9572] [STREAMING] [PYSPARK] Added StreamingContext.getActiveOrCreate()...Tathagata Das2015-08-112-14/+176
* [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-102-2/+176
* [SPARK-8564] [STREAMING] Add the Python API for Kinesiszsxwing2015-07-312-1/+197
* [SPARK-8389] [STREAMING] [PYSPARK] Expose KafkaRDDs offsetRange in Pythonjerryshao2015-07-093-11/+183
* [SPARK-8378] [STREAMING] Add the Python API for Flumezsxwing2015-07-012-2/+324
* [SPARK-8583] [SPARK-5482] [BUILD] Refactor python/run-tests to integrate with...Josh Rosen2015-06-271-0/+16
* [SPARK-8652] [PYSPARK] Check return value for all uses of doctest.testmod()Josh Rosen2015-06-261-1/+3
* [SPARK-8444] [STREAMING] Adding Python streaming example for queueStreamBryan Cutler2015-06-191-1/+1
* [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-6657] [PYSPARK] Fix doc warningsXiangrui Meng2015-05-181-1/+2
* [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-272-14/+237
* [SPARK-6953] [PySpark] speed up python testsReynold Xin2015-04-211-24/+39
* [SPARK-6949] [SQL] [PySpark] Support Date/Timestamp in Column expressionDavies Liu2015-04-213-18/+6
* [SPARK-4897] [PySpark] Python 3 supportDavies Liu2015-04-165-50/+59
* [SPARK-6211][Streaming] Add Python Kafka API unit testjerryshao2015-04-091-1/+42
* [Streaming][Minor]Fix some error docs in streaming examplesSaisai Shao2015-03-021-1/+1
* [SPARK-6027][SPARK-5546] Fixed --jar and --packages not working for KafkaUtil...Tathagata Das2015-02-261-15/+27
* [SPARK-5943][Streaming] Update the test to use new API to reduce the warningSaisai Shao2015-02-231-1/+1
* [SPARK-5785] [PySpark] narrow dependency for cogroup/join in PySparkDavies Liu2015-02-171-1/+1
* [SPARK-5379][Streaming] Add awaitTerminationOrTimeoutzsxwing2015-02-041-0/+9
* [SPARK-4969][STREAMING][PYTHON] Add binaryRecords to streamingfreeman2015-02-032-1/+30
* [SPARK-5154] [PySpark] [Streaming] Kafka streaming support in PythonDavies Liu2015-02-021-0/+83
* [SPARK-3325][Streaming] Add a parameter to the method print in class DStreamYadong Qi2015-01-021-5/+7
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-17 09:16:00 +0000