Commit a0d3263

Andrew Or

committed

Scope streaming operations instead of RDD operations

1 parent 3071aac commit a0d3263Copy full SHA for a0d3263

2 files changed

+177

-108

lines changed

streaming/src/main/scala/org/apache/spark/streaming/dstream
- DStream.scala
- PairDStreamFunctions.scala

+177

-108

lines changed

Comments

(0)