aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming/kafka.py
Commit message (Expand)AuthorAgeFilesLines
* [MINOR] Fix Typos 'a -> an'Zheng RuiFeng2016-05-261-1/+1
* [SPARK-15085][STREAMING][KAFKA] Rename streaming-kafka artifactcody koeninger2016-05-111-3/+3
* [SPARK-13848][SPARK-5185] Update to Py4J 0.9.2 in order to fix classloading i...Josh Rosen2016-03-141-7/+3
* [SPARK-13807] De-duplicate `Python*Helper` instantiation code in PySpark stre...Josh Rosen2016-03-111-59/+41
* [SPARK-12091] [PYSPARK] Deprecate the JAVA-specific deserialized storage levelsgatorsmile2015-12-181-1/+1
* [SPARK-9065][STREAMING][PYSPARK] Add MessageHandler for Kafka Python APIjerryshao2015-11-171-12/+99
* [SPARK-11270][STREAMING] Add improved equality testing for TopicAndPartition ...Nick Evans2015-10-271-0/+10
* [SPARK-10447][SPARK-3842][PYSPARK] upgrade pyspark to py4j0.9Holden Karau2015-10-201-1/+1
* [SPARK-9812] [STREAMING] Fix Python 3 compatibility issue in PySpark Streamin...zsxwing2015-08-191-1/+3
* [SPARK-9828] [PYSPARK] Mutable values should not be default argumentsMechCoder2015-08-141-3/+9
* [SPARK-8389] [STREAMING] [PYSPARK] Expose KafkaRDDs offsetRange in Pythonjerryshao2015-07-091-10/+113
* [SPARK-6657] [PYSPARK] Fix doc warningsXiangrui Meng2015-05-181-1/+2
* [SPARK-5946] [STREAMING] Add Python API for direct Kafka streamjerryshao2015-04-271-7/+160
* [SPARK-6949] [SQL] [PySpark] Support Date/Timestamp in Column expressionDavies Liu2015-04-211-5/+2
* [SPARK-4897] [PySpark] Python 3 supportDavies Liu2015-04-161-4/+4
* [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-5154] [PySpark] [Streaming] Kafka streaming support in PythonDavies Liu2015-02-021-0/+83