diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2015-05-18 18:24:15 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-05-18 18:24:15 -0700 |
commit | 3a6003866ade45974b43a9e785ec35fb76a32b99 (patch) | |
tree | f41298288d49478b61e87ed04cf2260814d351d2 /python/pyspark/context.py | |
parent | 0a7a94eab5fba3d2f2ef14a70c2c1bf4ee21b626 (diff) | |
download | spark-3a6003866ade45974b43a9e785ec35fb76a32b99.tar.gz spark-3a6003866ade45974b43a9e785ec35fb76a32b99.tar.bz2 spark-3a6003866ade45974b43a9e785ec35fb76a32b99.zip |
[SPARK-7692] Updated Kinesis examples
- Updated Kinesis examples to use stable API
- Cleaned up comments, etc.
- Renamed KinesisWordCountProducerASL to KinesisWordProducerASL
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #6249 from tdas/kinesis-examples and squashes the following commits:
7cc307b [Tathagata Das] More tweaks
f080872 [Tathagata Das] More cleanup
841987f [Tathagata Das] Small update
011cbe2 [Tathagata Das] More fixes
b0d74f9 [Tathagata Das] Updated examples.
Diffstat (limited to 'python/pyspark/context.py')
0 files changed, 0 insertions, 0 deletions