-
- Downloads
Merge pull request #494 from mesos/streaming
Final set of Spark Streaming changes
No related branches found
No related tags found
Showing
- core/src/main/scala/spark/rdd/CheckpointRDD.scala 4 additions, 4 deletionscore/src/main/scala/spark/rdd/CheckpointRDD.scala
- core/src/main/scala/spark/util/MetadataCleaner.scala 2 additions, 2 deletionscore/src/main/scala/spark/util/MetadataCleaner.scala
- core/src/test/scala/spark/CheckpointSuite.scala 10 additions, 0 deletionscore/src/test/scala/spark/CheckpointSuite.scala
- docs/configuration.md 3 additions, 3 deletionsdocs/configuration.md
- docs/python-programming-guide.md 1 addition, 1 deletiondocs/python-programming-guide.md
- docs/streaming-custom-receivers.md 101 additions, 0 deletionsdocs/streaming-custom-receivers.md
- docs/streaming-programming-guide.md 260 additions, 55 deletionsdocs/streaming-programming-guide.md
- examples/pom.xml 3 additions, 4 deletionsexamples/pom.xml
- examples/src/main/java/spark/streaming/examples/JavaFlumeEventCount.java 0 additions, 0 deletions...in/java/spark/streaming/examples/JavaFlumeEventCount.java
- examples/src/main/java/spark/streaming/examples/JavaNetworkWordCount.java 2 additions, 2 deletions...n/java/spark/streaming/examples/JavaNetworkWordCount.java
- examples/src/main/java/spark/streaming/examples/JavaQueueStream.java 0 additions, 0 deletions...c/main/java/spark/streaming/examples/JavaQueueStream.java
- examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala 157 additions, 0 deletions.../main/scala/spark/streaming/examples/ActorWordCount.scala
- examples/src/main/scala/spark/streaming/examples/KafkaWordCount.scala 20 additions, 8 deletions.../main/scala/spark/streaming/examples/KafkaWordCount.scala
- examples/src/main/scala/spark/streaming/examples/NetworkWordCount.scala 2 additions, 2 deletions...ain/scala/spark/streaming/examples/NetworkWordCount.scala
- examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala 1 addition, 1 deletion.../main/scala/spark/streaming/examples/RawNetworkGrep.scala
- examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala 93 additions, 0 deletions...n/scala/spark/streaming/examples/TwitterAlgebirdCMS.scala
- examples/src/main/scala/spark/streaming/examples/TwitterAlgebirdHLL.scala 71 additions, 0 deletions...n/scala/spark/streaming/examples/TwitterAlgebirdHLL.scala
- examples/src/main/scala/spark/streaming/examples/TwitterPopularTags.scala 13 additions, 20 deletions...n/scala/spark/streaming/examples/TwitterPopularTags.scala
- examples/src/main/scala/spark/streaming/examples/ZeroMQWordCount.scala 73 additions, 0 deletions...main/scala/spark/streaming/examples/ZeroMQWordCount.scala
- examples/src/main/scala/spark/streaming/examples/clickstream/PageViewStream.scala 6 additions, 7 deletions...spark/streaming/examples/clickstream/PageViewStream.scala
Loading
Please register or sign in to comment