diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2014-01-11 10:50:14 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-01-12 17:21:00 -0800 |
| commit | f4d77f8cb8a9eab43bea35e8e6c9bc0d2c2b53a8 (patch) | |
| tree | 1736b3b4545e8ff5ba5f9ffe66cddabdaefaf449 /ec2 | |
| parent | 288a878999848adb130041d1e40c14bfc879cec6 (diff) | |
| download | spark-f4d77f8cb8a9eab43bea35e8e6c9bc0d2c2b53a8.tar.gz spark-f4d77f8cb8a9eab43bea35e8e6c9bc0d2c2b53a8.tar.bz2 spark-f4d77f8cb8a9eab43bea35e8e6c9bc0d2c2b53a8.zip | |
Rename DStream.foreach to DStream.foreachRDD
`foreachRDD` makes it clear that the granularity of this operator is per-RDD.
As it stands, `foreach` is inconsistent with with `map`, `filter`, and the other
DStream operators which get pushed down to individual records within each RDD.
Diffstat (limited to 'ec2')
0 files changed, 0 insertions, 0 deletions