-
- Downloads
Refactored streaming project to separate out the twitter functionality.
Showing
- examples/src/main/scala/org/apache/spark/streaming/examples/TwitterAlgebirdCMS.scala 2 additions, 0 deletions.../apache/spark/streaming/examples/TwitterAlgebirdCMS.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/TwitterAlgebirdHLL.scala 1 addition, 1 deletion.../apache/spark/streaming/examples/TwitterAlgebirdHLL.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/TwitterPopularTags.scala 1 addition, 0 deletions.../apache/spark/streaming/examples/TwitterPopularTags.scala
- external/twitter/src/main/scala/org/apache/spark/streaming/twitter/StreamingContextWithTwitter.scala 27 additions, 0 deletions...spark/streaming/twitter/StreamingContextWithTwitter.scala
- external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala 7 additions, 5 deletions.../apache/spark/streaming/twitter/TwitterInputDStream.scala
- external/twitter/src/main/scala/org/apache/spark/streaming/twitter/package.scala 7 additions, 0 deletions...in/scala/org/apache/spark/streaming/twitter/package.scala
- project/SparkBuild.scala 11 additions, 2 deletionsproject/SparkBuild.scala
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 4 additions, 2 deletions...n/scala/org/apache/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala 4 additions, 4 deletions...pache/spark/streaming/api/java/JavaStreamingContext.scala
Loading
Please register or sign in to comment