-
- Downloads
Merge pull request #398 from pwendell/streaming-api
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.
No related branches found
No related tags found
Showing
- docs/streaming-programming-guide.md 2 additions, 2 deletionsdocs/streaming-programming-guide.md
- examples/src/main/scala/org/apache/spark/streaming/examples/RawNetworkGrep.scala 1 addition, 1 deletion.../org/apache/spark/streaming/examples/RawNetworkGrep.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/TwitterAlgebirdCMS.scala 2 additions, 2 deletions.../apache/spark/streaming/examples/TwitterAlgebirdCMS.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/TwitterAlgebirdHLL.scala 2 additions, 2 deletions.../apache/spark/streaming/examples/TwitterAlgebirdHLL.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/TwitterPopularTags.scala 2 additions, 2 deletions.../apache/spark/streaming/examples/TwitterPopularTags.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/clickstream/PageViewStream.scala 1 addition, 1 deletion...spark/streaming/examples/clickstream/PageViewStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/DStream.scala 28 additions, 13 deletions...g/src/main/scala/org/apache/spark/streaming/DStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/PairDStreamFunctions.scala 2 additions, 2 deletions...ala/org/apache/spark/streaming/PairDStreamFunctions.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala 24 additions, 2 deletions...org/apache/spark/streaming/api/java/JavaDStreamLike.scala
- streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala 1 addition, 1 deletion...ala/org/apache/spark/streaming/BasicOperationsSuite.scala
Loading
Please register or sign in to comment