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 /data/kmeans_data.txt | |
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 'data/kmeans_data.txt')
0 files changed, 0 insertions, 0 deletions