diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2015-07-23 20:06:54 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-07-23 20:06:54 -0700 |
| commit | d249636e59fabd8ca57a47dc2cbad9c4a4e7a750 (patch) | |
| tree | b26062dec22c2c6156993d4398e427ee62b74f55 /mllib | |
| parent | 52de3acca4ce8c36fd4c9ce162473a091701bbc7 (diff) | |
| download | spark-d249636e59fabd8ca57a47dc2cbad9c4a4e7a750.tar.gz spark-d249636e59fabd8ca57a47dc2cbad9c4a4e7a750.tar.bz2 spark-d249636e59fabd8ca57a47dc2cbad9c4a4e7a750.zip | |
[SPARK-9216] [STREAMING] Define KinesisBackedBlockRDDs
For more information see master JIRA: https://issues.apache.org/jira/browse/SPARK-9215
Design Doc: https://docs.google.com/document/d/1k0dl270EnK7uExrsCE7jYw7PYx0YC935uBcxn3p0f58/edit
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #7578 from tdas/kinesis-rdd and squashes the following commits:
543d208 [Tathagata Das] Fixed scala style
5082a30 [Tathagata Das] Fixed scala style
3f40c2d [Tathagata Das] Addressed comments
c4f25d2 [Tathagata Das] Addressed comment
d3d64d1 [Tathagata Das] Minor update
f6e35c8 [Tathagata Das] Added retry logic to make it more robust
8874b70 [Tathagata Das] Updated Kinesis RDD
575bdbc [Tathagata Das] Fix scala style issues
4a36096 [Tathagata Das] Add license
5da3995 [Tathagata Das] Changed KinesisSuiteHelper to KinesisFunSuite
528e206 [Tathagata Das] Merge remote-tracking branch 'apache-github/master' into kinesis-rdd
3ae0814 [Tathagata Das] Added KinesisBackedBlockRDD
Diffstat (limited to 'mllib')
0 files changed, 0 insertions, 0 deletions