Renamed stream package to streaming

startTrigger.sh

@@ -1,3 +1,3 @@
 #!/bin/bash
 
-./run spark.stream.SentenceGenerator localhost 7078 sentences.txt 1
+./run spark.streaming.SentenceGenerator localhost 7078 sentences.txt 1

streaming/src/main/scala/spark/streaming/BlockID.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 case class BlockID(sRds: String, sInterval: Interval, sPartition: Int) {
   override def toString : String = (

streaming/src/main/scala/spark/streaming/ConnectionHandler.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.Logging
 

streaming/src/main/scala/spark/streaming/DumbTopKWordCount2_Special.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkContext
 import SparkContext._

streaming/src/main/scala/spark/streaming/DumbWordCount2_Special.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkContext
 import SparkContext._

streaming/src/main/scala/spark/streaming/FileStreamReceiver.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.Logging
 

streaming/src/main/scala/spark/streaming/GrepCount.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 

streaming/src/main/scala/spark/streaming/GrepCount2.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 

streaming/src/main/scala/spark/streaming/GrepCountApprox.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 

streaming/src/main/scala/spark/streaming/IdealPerformance.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import scala.collection.mutable.Map
 

streaming/src/main/scala/spark/streaming/Interval.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 case class Interval (val beginTime: Time, val endTime: Time) {
   

streaming/src/main/scala/spark/streaming/Job.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 class Job(val time: Time, func: () => _) {
   val id = Job.getNewId()

streaming/src/main/scala/spark/streaming/JobManager.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkEnv
 import spark.Logging

streaming/src/main/scala/spark/streaming/JobManager2.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.{Logging, SparkEnv}
 import java.util.concurrent.Executors

streaming/src/main/scala/spark/streaming/NetworkStreamReceiver.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.Logging
 import spark.storage.StorageLevel

streaming/src/main/scala/spark/streaming/RDS.scala

@@ -1,6 +1,6 @@
-package spark.stream
+package spark.streaming
 
-import spark.stream.SparkStreamContext._
+import spark.streaming.SparkStreamContext._
 
 import spark.RDD
 import spark.BlockRDD
@@ -41,7 +41,7 @@ extends Logging with Serializable {
   @transient private val generatedRDDs = new HashMap[Time, RDD[T]] ()
   
   // Variable to be set to the first time seen by the RDS (effective time zero)
-  private[stream] var zeroTime: Time = null 
+  private[streaming] var zeroTime: Time = null
 
   // Variable to specify storage level
   private var storageLevel: StorageLevel = StorageLevel.NONE

streaming/src/main/scala/spark/streaming/ReducedWindowedRDS.scala

@@ -1,6 +1,6 @@
-package spark.stream
+package spark.streaming
 
-import spark.stream.SparkStreamContext._
+import spark.streaming.SparkStreamContext._
 
 import spark.RDD
 import spark.UnionRDD

streaming/src/main/scala/spark/streaming/Scheduler.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkEnv
 import spark.Logging

streaming/src/main/scala/spark/streaming/SenGeneratorForPerformanceTest.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import scala.util.Random
 import scala.io.Source

streaming/src/main/scala/spark/streaming/SenderReceiverTest.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 import java.net.{Socket, ServerSocket}
 import java.io.{ByteArrayOutputStream, DataOutputStream, DataInputStream, BufferedInputStream}
 

streaming/src/main/scala/spark/streaming/SentenceFileGenerator.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark._
 

streaming/src/main/scala/spark/streaming/SentenceGenerator.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import scala.util.Random
 import scala.io.Source

streaming/src/main/scala/spark/streaming/ShuffleTest.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 import spark.SparkContext
 import SparkContext._
 

streaming/src/main/scala/spark/streaming/SimpleWordCount.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 

streaming/src/main/scala/spark/streaming/SimpleWordCount2.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkContext
 import SparkContext._

streaming/src/main/scala/spark/streaming/SimpleWordCount2_Special.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkContext
 import SparkContext._

streaming/src/main/scala/spark/streaming/SparkStreamContext.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkContext
 import spark.SparkEnv

streaming/src/main/scala/spark/streaming/TestGenerator.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import scala.util.Random
 import scala.io.Source

streaming/src/main/scala/spark/streaming/TestGenerator2.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import scala.util.Random
 import scala.io.Source

streaming/src/main/scala/spark/streaming/TestGenerator4.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.Logging
 

streaming/src/main/scala/spark/streaming/TestInputBlockTracker.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 import spark.Logging
 import scala.collection.mutable.{ArrayBuffer, HashMap}
 

streaming/src/main/scala/spark/streaming/TestStreamCoordinator.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.Logging
 

streaming/src/main/scala/spark/streaming/TestStreamReceiver3.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark._
 import spark.storage._

streaming/src/main/scala/spark/streaming/TestStreamReceiver4.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark._
 import spark.storage._

streaming/src/main/scala/spark/streaming/Time.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 abstract case class Time {
 

streaming/src/main/scala/spark/streaming/TopContentCount.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 

streaming/src/main/scala/spark/streaming/TopKWordCount2.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkContext
 import SparkContext._

streaming/src/main/scala/spark/streaming/TopKWordCount2_Special.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkContext
 import SparkContext._

streaming/src/main/scala/spark/streaming/WindowedRDS.scala

@@ -1,6 +1,6 @@
-package spark.stream
+package spark.streaming
 
-import spark.stream.SparkStreamContext._
+import spark.streaming.SparkStreamContext._
 
 import spark.RDD
 import spark.UnionRDD

streaming/src/main/scala/spark/streaming/WordCount.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 

streaming/src/main/scala/spark/streaming/WordCount1.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 

streaming/src/main/scala/spark/streaming/WordCount2.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkContext
 import SparkContext._

streaming/src/main/scala/spark/streaming/WordCount2_Special.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import spark.SparkContext
 import SparkContext._

streaming/src/main/scala/spark/streaming/WordCount3.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 

streaming/src/main/scala/spark/streaming/WordCountEc2.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 import spark.SparkContext

streaming/src/main/scala/spark/streaming/WordCountTrivialWindow.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._
 

streaming/src/main/scala/spark/streaming/WordMax.scala

@@ -1,4 +1,4 @@
-package spark.stream
+package spark.streaming
 
 import SparkStreamContext._