spark-instrumented-optimizer/python/pyspark/streaming
jerryshao d89cc38b33 [SPARK-10122] [PYSPARK] [STREAMING] Fix getOffsetRanges bug in PySpark-Streaming transform function
Details of the bug and explanations can be seen in [SPARK-10122](https://issues.apache.org/jira/browse/SPARK-10122).

tdas , please help to review.

Author: jerryshao <sshao@hortonworks.com>

Closes #8347 from jerryshao/SPARK-10122 and squashes the following commits:

4039b16 [jerryshao] Fix getOffsetRanges in transform() bug
2015-08-21 13:15:35 -07:00
..
__init__.py [SPARK-2377] Python API for Streaming 2014-10-12 02:46:56 -07:00
context.py [SPARK-9572] [STREAMING] [PYSPARK] Added StreamingContext.getActiveOrCreate() in Python 2015-08-11 12:02:28 -07:00
dstream.py [SPARK-10122] [PYSPARK] [STREAMING] Fix getOffsetRanges bug in PySpark-Streaming transform function 2015-08-21 13:15:35 -07:00
flume.py [SPARK-9812] [STREAMING] Fix Python 3 compatibility issue in PySpark Streaming and some docs 2015-08-19 18:36:01 -07:00
kafka.py [SPARK-9812] [STREAMING] Fix Python 3 compatibility issue in PySpark Streaming and some docs 2015-08-19 18:36:01 -07:00
kinesis.py [SPARK-9812] [STREAMING] Fix Python 3 compatibility issue in PySpark Streaming and some docs 2015-08-19 18:36:01 -07:00
mqtt.py [SPARK-5155] [PYSPARK] [STREAMING] Mqtt streaming support in Python 2015-08-10 16:33:23 -07:00
tests.py [SPARK-10122] [PYSPARK] [STREAMING] Fix getOffsetRanges bug in PySpark-Streaming transform function 2015-08-21 13:15:35 -07:00
util.py [SPARK-8389] [STREAMING] [PYSPARK] Expose KafkaRDDs offsetRange in Python 2015-07-09 13:54:44 -07:00