-
- Downloads
Include a default OAuth implementation, and update examples and JavaStreamingContext
Showing
- examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala 1 addition, 1 deletion...n/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala
- examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdHLL.scala 1 addition, 1 deletion...n/scala/spark/streaming/examples/TwitterAlgebirdHLL.scala
- examples/src/main/scala/spark/streaming/examples/TwitterPopularTags.scala 1 addition, 1 deletion...n/scala/spark/streaming/examples/TwitterPopularTags.scala
- streaming/src/main/scala/spark/streaming/StreamingContext.scala 1 addition, 1 deletion...ing/src/main/scala/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala 48 additions, 21 deletions...scala/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/main/scala/spark/streaming/dstream/TwitterInputDStream.scala 29 additions, 3 deletions...n/scala/spark/streaming/dstream/TwitterInputDStream.scala
Loading
Please register or sign in to comment