aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming
Commit message (Expand)AuthorAgeFilesLines
* [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
* [DOC][PySpark][Streaming] Fix docstring for sphinxKen Takagiwa2014-11-191-2/+2
* replace awaitTransformation with awaitTermination in scaladoc/javadocHolden Karau2014-10-211-1/+1
* [SPARK-3952] [Streaming] [PySpark] add Python examples in Streaming Programmi...Davies Liu2014-10-181-3/+5
* [SPARK-2377] Python API for Streaminggiwa2014-10-125-0/+1640