Commit 23b54f62 authored 12 years ago by Tathagata Das

Merge pull request #366 from tdas/streaming

Code refactoring

parents 530493b0 365506fb

No related branches found

No related tags found

No related merge requests found

Hide whitespace changes

Inline Side-by-side

Showing

examples/src/main/scala/spark/streaming/examples/twitter/TwitterBasic.scala 60 additions, 0 deletions

...scala/spark/streaming/examples/twitter/TwitterBasic.scala
examples/src/main/scala/spark/streaming/examples/twitter/TwitterInputDStream.scala 70 additions, 0 deletions

...park/streaming/examples/twitter/TwitterInputDStream.scala
project/SparkBuild.scala 4 additions, 1 deletion

project/SparkBuild.scala
streaming/src/main/scala/spark/streaming/Checkpoint.scala 1 addition, 1 deletion

streaming/src/main/scala/spark/streaming/Checkpoint.scala
streaming/src/main/scala/spark/streaming/DStream.scala 50 additions, 50 deletions

streaming/src/main/scala/spark/streaming/DStream.scala
streaming/src/main/scala/spark/streaming/DStreamGraph.scala 4 additions, 4 deletions

streaming/src/main/scala/spark/streaming/DStreamGraph.scala
streaming/src/main/scala/spark/streaming/Duration.scala 62 additions, 0 deletions

streaming/src/main/scala/spark/streaming/Duration.scala
streaming/src/main/scala/spark/streaming/Interval.scala 10 additions, 20 deletions

streaming/src/main/scala/spark/streaming/Interval.scala
streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala 33 additions, 37 deletions

...src/main/scala/spark/streaming/PairDStreamFunctions.scala
streaming/src/main/scala/spark/streaming/Scheduler.scala 5 additions, 4 deletions

streaming/src/main/scala/spark/streaming/Scheduler.scala
streaming/src/main/scala/spark/streaming/StreamingContext.scala 11 additions, 11 deletions

...ing/src/main/scala/spark/streaming/StreamingContext.scala
streaming/src/main/scala/spark/streaming/Time.scala 17 additions, 54 deletions

streaming/src/main/scala/spark/streaming/Time.scala
streaming/src/main/scala/spark/streaming/dstream/CoGroupedDStream.scala 3 additions, 3 deletions

...main/scala/spark/streaming/dstream/CoGroupedDStream.scala
streaming/src/main/scala/spark/streaming/dstream/DataHandler.scala 0 additions, 83 deletions

.../src/main/scala/spark/streaming/dstream/DataHandler.scala
streaming/src/main/scala/spark/streaming/dstream/FilteredDStream.scala 2 additions, 2 deletions

.../main/scala/spark/streaming/dstream/FilteredDStream.scala
streaming/src/main/scala/spark/streaming/dstream/FlatMapValuedDStream.scala 2 additions, 2 deletions

.../scala/spark/streaming/dstream/FlatMapValuedDStream.scala
streaming/src/main/scala/spark/streaming/dstream/FlatMappedDStream.scala 2 additions, 2 deletions

...ain/scala/spark/streaming/dstream/FlatMappedDStream.scala
streaming/src/main/scala/spark/streaming/dstream/FlumeInputDStream.scala 5 additions, 5 deletions

...ain/scala/spark/streaming/dstream/FlumeInputDStream.scala
streaming/src/main/scala/spark/streaming/dstream/ForEachDStream.scala 2 additions, 2 deletions

...c/main/scala/spark/streaming/dstream/ForEachDStream.scala
streaming/src/main/scala/spark/streaming/dstream/GlommedDStream.scala 2 additions, 2 deletions

...c/main/scala/spark/streaming/dstream/GlommedDStream.scala

with 345 additions and 283 deletions

Please register or to comment