aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming/kafka.py
Commit message (Expand)AuthorAgeFilesLines
* [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