-
- Downloads
Merge pull request #661 from mesos/streaming
Kafka fixes and DStream.count fix for master
No related branches found
No related tags found
Showing
- .gitignore 1 addition, 0 deletions.gitignore
- docs/configuration.md 7 additions, 0 deletionsdocs/configuration.md
- examples/src/main/scala/spark/streaming/examples/KafkaWordCount.scala 1 addition, 1 deletion.../main/scala/spark/streaming/examples/KafkaWordCount.scala
- project/SparkBuild.scala 3 additions, 0 deletionsproject/SparkBuild.scala
- streaming/src/main/scala/spark/streaming/DStream.scala 7 additions, 2 deletionsstreaming/src/main/scala/spark/streaming/DStream.scala
- streaming/src/main/scala/spark/streaming/StreamingContext.scala 34 additions, 15 deletions...ing/src/main/scala/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala 27 additions, 30 deletions...scala/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala 46 additions, 48 deletions...ain/scala/spark/streaming/dstream/KafkaInputDStream.scala
- streaming/src/main/scala/spark/streaming/dstream/NetworkInputDStream.scala 1 addition, 1 deletion...n/scala/spark/streaming/dstream/NetworkInputDStream.scala
- streaming/src/test/java/spark/streaming/JavaAPISuite.java 8 additions, 4 deletionsstreaming/src/test/java/spark/streaming/JavaAPISuite.java
- streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala 2 additions, 2 deletions...src/test/scala/spark/streaming/BasicOperationsSuite.scala
- streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala 11 additions, 0 deletions...ng/src/test/scala/spark/streaming/InputStreamsSuite.scala
Loading
Please register or sign in to comment