Commit a0d3263

Andrew Or

committed

Scope streaming operations instead of RDD operations

1 parent 3071aac commit a0d3263Copy full SHA for a0d3263

2 files changed

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

Comments

(0)

Provide feedback