-
- Downloads
Merge pull request #370 from tdas/streaming
Added more documentation and minor change in API for NetworkReceiver
No related branches found
No related tags found
Showing
- core/src/main/scala/spark/PairRDDFunctions.scala 3 additions, 3 deletionscore/src/main/scala/spark/PairRDDFunctions.scala
- docs/streaming-programming-guide.md 25 additions, 20 deletionsdocs/streaming-programming-guide.md
- examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala 8 additions, 7 deletions...park/streaming/examples/twitter/TwitterInputDStream.scala
- streaming/src/main/scala/spark/streaming/DStream.scala 23 additions, 14 deletionsstreaming/src/main/scala/spark/streaming/DStream.scala
- streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala 26 additions, 8 deletions.../src/main/scala/spark/streaming/NetworkInputTracker.scala
- streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala 280 additions, 13 deletions...src/main/scala/spark/streaming/PairDStreamFunctions.scala
- streaming/src/main/scala/spark/streaming/dstream/FlumeInputDStream.scala 2 additions, 3 deletions...ain/scala/spark/streaming/dstream/FlumeInputDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala 3 additions, 3 deletions...ain/scala/spark/streaming/dstream/KafkaInputDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala 32 additions, 10 deletions...n/scala/spark/streaming/dstream/NetworkInputDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/RawInputDStream.scala 3 additions, 3 deletions.../main/scala/spark/streaming/dstream/RawInputDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/SocketInputDStream.scala 2 additions, 3 deletions...in/scala/spark/streaming/dstream/SocketInputDStream.scala
- streaming/src/main/scala/spark/streaming/util/RawTextHelper.scala 1 addition, 1 deletion...g/src/main/scala/spark/streaming/util/RawTextHelper.scala
- streaming/src/test/scala/spark/streaming/WindowOperationsSuite.scala 3 additions, 1 deletion...rc/test/scala/spark/streaming/WindowOperationsSuite.scala
Loading
Please register or sign in to comment