aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-18447][DOCS] Fix the markdown for `Note:`/`NOTE:`/`Note that` across P...hyukjinkwon2016-11-222-3/+3
* [SPARK-18445][BUILD][DOCS] Fix the markdown for `Note:`/`NOTE:`/`Note that`/`...hyukjinkwon2016-11-191-2/+2
* [SPARK-16950] [PYSPARK] fromOffsets parameter support in KafkaUtils.createDir...Mariusz Strzelecki2016-08-092-9/+6
* [MINOR] Fix Typos 'an -> a'Zheng RuiFeng2016-06-061-2/+2
* [MINOR] Fix Typos 'a -> an'Zheng RuiFeng2016-05-262-2/+2
* [SPARK-15085][STREAMING][KAFKA] Rename streaming-kafka artifactcody koeninger2016-05-112-6/+6
* [SPARK-14936][BUILD][TESTS] FlumePollingStreamSuite is slowXin Ren2016-05-101-1/+1
* [SPARK-9819][STREAMING][DOCUMENTATION] Clarify doc for invReduceFunc in incre...François Garillot2016-05-031-1/+3
* [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-252-3/+305
* [SPARK-13843][STREAMING] Remove streaming-flume, streaming-mqtt, streaming-ze...Shixiong Zhu2016-03-143-473/+3
* [SPARK-13848][SPARK-5185] Update to Py4J 0.9.2 in order to fix classloading i...Josh Rosen2016-03-145-49/+22
* [SPARK-13807] De-duplicate `Python*Helper` instantiation code in PySpark stre...Josh Rosen2016-03-114-84/+60
* [SPARK-13595][BUILD] Move docker, extras modules into externalSean Owen2016-03-091-1/+1
* [SPARK-13339][DOCS] Clarify commutative / associative operator requirements f...Sean Owen2016-02-191-2/+2
* [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-12652][PYSPARK] Upgrade Py4J to 0.9.1Shixiong Zhu2016-01-122-87/+5
* [SPARK-12617][PYSPARK] Move Py4jCallbackConnectionCleaner to StreamingShixiong Zhu2016-01-061-0/+63
* [SPARK-12511] [PYSPARK] [STREAMING] Make sure PythonDStream.registerSerialize...Shixiong Zhu2016-01-052-10/+26
* [SPARK-12353][STREAMING][PYSPARK] Fix countByValue inconsistent output in Pyt...jerryshao2015-12-282-5/+16
* [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
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-01 03:32:03 +0000