-
- Downloads
Merge pull request #493 from tdas/streaming
Streaming bug fixes
No related branches found
No related tags found
Showing
- .gitignore 2 additions, 0 deletions.gitignore
- core/src/main/scala/spark/RDD.scala 21 additions, 0 deletionscore/src/main/scala/spark/RDD.scala
- core/src/main/scala/spark/SparkContext.scala 1 addition, 1 deletioncore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/api/java/JavaDoubleRDD.scala 22 additions, 1 deletioncore/src/main/scala/spark/api/java/JavaDoubleRDD.scala
- core/src/main/scala/spark/api/java/JavaPairRDD.scala 24 additions, 3 deletionscore/src/main/scala/spark/api/java/JavaPairRDD.scala
- core/src/main/scala/spark/api/java/JavaRDD.scala 20 additions, 0 deletionscore/src/main/scala/spark/api/java/JavaRDD.scala
- core/src/main/scala/spark/api/java/JavaRDDLike.scala 7 additions, 6 deletionscore/src/main/scala/spark/api/java/JavaRDDLike.scala
- core/src/main/scala/spark/api/java/PairFlatMapWorkaround.java 0 additions, 20 deletions.../src/main/scala/spark/api/java/PairFlatMapWorkaround.java
- core/src/main/scala/spark/deploy/master/Master.scala 11 additions, 2 deletionscore/src/main/scala/spark/deploy/master/Master.scala
- core/src/main/scala/spark/network/Connection.scala 20 additions, 4 deletionscore/src/main/scala/spark/network/Connection.scala
- core/src/main/scala/spark/rdd/HadoopRDD.scala 11 additions, 6 deletionscore/src/main/scala/spark/rdd/HadoopRDD.scala
- core/src/main/scala/spark/rdd/NewHadoopRDD.scala 12 additions, 3 deletionscore/src/main/scala/spark/rdd/NewHadoopRDD.scala
- core/src/main/scala/spark/rdd/SubtractedRDD.scala 108 additions, 0 deletionscore/src/main/scala/spark/rdd/SubtractedRDD.scala
- core/src/main/scala/spark/scheduler/cluster/ClusterScheduler.scala 25 additions, 1 deletion...main/scala/spark/scheduler/cluster/ClusterScheduler.scala
- core/src/main/scala/spark/util/MetadataCleaner.scala 2 additions, 2 deletionscore/src/main/scala/spark/util/MetadataCleaner.scala
- core/src/main/scala/spark/util/Vector.scala 10 additions, 0 deletionscore/src/main/scala/spark/util/Vector.scala
- core/src/test/scala/spark/DistributedSuite.scala 21 additions, 0 deletionscore/src/test/scala/spark/DistributedSuite.scala
- core/src/test/scala/spark/ShuffleSuite.scala 26 additions, 0 deletionscore/src/test/scala/spark/ShuffleSuite.scala
- docs/configuration.md 3 additions, 3 deletionsdocs/configuration.md
- docs/streaming-programming-guide.md 75 additions, 12 deletionsdocs/streaming-programming-guide.md
Loading
Please register or sign in to comment