-
- Downloads
Merge branch 'streaming' into ScrapCodes-streaming-actor
Conflicts: docs/plugin-custom-receiver.md streaming/src/main/scala/spark/streaming/StreamingContext.scala streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala streaming/src/main/scala/spark/streaming/dstream/PluggableInputDStream.scala streaming/src/main/scala/spark/streaming/receivers/ActorReceiver.scala streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala
No related branches found
No related tags found
Showing
- bagel/pom.xml 0 additions, 11 deletionsbagel/pom.xml
- bagel/src/test/scala/bagel/BagelSuite.scala 1 addition, 1 deletionbagel/src/test/scala/bagel/BagelSuite.scala
- bin/start-master.sh 2 additions, 1 deletionbin/start-master.sh
- core/pom.xml 5 additions, 11 deletionscore/pom.xml
- core/src/main/scala/spark/Accumulators.scala 1 addition, 2 deletionscore/src/main/scala/spark/Accumulators.scala
- core/src/main/scala/spark/CacheManager.scala 65 additions, 0 deletionscore/src/main/scala/spark/CacheManager.scala
- core/src/main/scala/spark/CacheTracker.scala 0 additions, 240 deletionscore/src/main/scala/spark/CacheTracker.scala
- core/src/main/scala/spark/DaemonThreadFactory.scala 0 additions, 18 deletionscore/src/main/scala/spark/DaemonThreadFactory.scala
- core/src/main/scala/spark/Dependency.scala 7 additions, 3 deletionscore/src/main/scala/spark/Dependency.scala
- core/src/main/scala/spark/HttpFileServer.scala 3 additions, 5 deletionscore/src/main/scala/spark/HttpFileServer.scala
- core/src/main/scala/spark/HttpServer.scala 8 additions, 1 deletioncore/src/main/scala/spark/HttpServer.scala
- core/src/main/scala/spark/KryoSerializer.scala 4 additions, 1 deletioncore/src/main/scala/spark/KryoSerializer.scala
- core/src/main/scala/spark/Logging.scala 1 addition, 2 deletionscore/src/main/scala/spark/Logging.scala
- core/src/main/scala/spark/MapOutputTracker.scala 8 additions, 8 deletionscore/src/main/scala/spark/MapOutputTracker.scala
- core/src/main/scala/spark/PairRDDFunctions.scala 5 additions, 19 deletionscore/src/main/scala/spark/PairRDDFunctions.scala
- core/src/main/scala/spark/ParallelCollection.scala 5 additions, 10 deletionscore/src/main/scala/spark/ParallelCollection.scala
- core/src/main/scala/spark/RDD.scala 122 additions, 70 deletionscore/src/main/scala/spark/RDD.scala
- core/src/main/scala/spark/RDDCheckpointData.scala 10 additions, 9 deletionscore/src/main/scala/spark/RDDCheckpointData.scala
- core/src/main/scala/spark/SparkContext.scala 141 additions, 47 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/SparkEnv.scala 32 additions, 25 deletionscore/src/main/scala/spark/SparkEnv.scala
Loading
Please register or sign in to comment