-
- Downloads
Fixed bugs in RawNetworkInputDStream and in its examples. Made the...
Fixed bugs in RawNetworkInputDStream and in its examples. Made the ReducedWindowedDStream persist RDDs to MEMOERY_SER_ONLY by default. Removed unncessary examples. Added streaming-env.sh.template to add recommended setting for streaming.
Showing
- conf/streaming-env.sh.template 22 additions, 0 deletionsconf/streaming-env.sh.template
- run 4 additions, 0 deletionsrun
- startTrigger.sh 0 additions, 3 deletionsstartTrigger.sh
- streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala 1 addition, 0 deletions.../src/main/scala/spark/streaming/NetworkInputTracker.scala
- streaming/src/main/scala/spark/streaming/RawInputDStream.scala 1 addition, 1 deletion...ming/src/main/scala/spark/streaming/RawInputDStream.scala
- streaming/src/main/scala/spark/streaming/ReducedWindowedDStream.scala 6 additions, 9 deletions...c/main/scala/spark/streaming/ReducedWindowedDStream.scala
- streaming/src/main/scala/spark/streaming/StreamingContext.scala 2 additions, 2 deletions...ing/src/main/scala/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/spark/streaming/examples/Grep2.scala 0 additions, 64 deletions...aming/src/main/scala/spark/streaming/examples/Grep2.scala
- streaming/src/main/scala/spark/streaming/examples/GrepRaw.scala 5 additions, 6 deletions...ing/src/main/scala/spark/streaming/examples/GrepRaw.scala
- streaming/src/main/scala/spark/streaming/examples/TopKWordCountRaw.scala 29 additions, 73 deletions...ain/scala/spark/streaming/examples/TopKWordCountRaw.scala
- streaming/src/main/scala/spark/streaming/examples/WordCountRaw.scala 25 additions, 32 deletions...rc/main/scala/spark/streaming/examples/WordCountRaw.scala
- streaming/src/main/scala/spark/streaming/examples/WordMax2.scala 0 additions, 75 deletions...ng/src/main/scala/spark/streaming/examples/WordMax2.scala
- streaming/src/main/scala/spark/streaming/util/RawTextHelper.scala 98 additions, 0 deletions...g/src/main/scala/spark/streaming/util/RawTextHelper.scala
Loading
Please register or sign in to comment