diff options
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/FileStream.scala (renamed from streaming/src/main/scala/spark/streaming/examples/FileStream.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/FileStreamWithCheckpoint.scala (renamed from streaming/src/main/scala/spark/streaming/examples/FileStreamWithCheckpoint.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/FlumeEventCount.scala (renamed from streaming/src/main/scala/spark/streaming/examples/FlumeEventCount.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/GrepRaw.scala (renamed from streaming/src/main/scala/spark/streaming/examples/GrepRaw.scala) | 1 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/KafkaWordCount.scala (renamed from streaming/src/main/scala/spark/streaming/examples/KafkaWordCount.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/QueueStream.scala (renamed from streaming/src/main/scala/spark/streaming/examples/QueueStream.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/TopKWordCountRaw.scala (renamed from streaming/src/main/scala/spark/streaming/examples/TopKWordCountRaw.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/WordCountHdfs.scala (renamed from streaming/src/main/scala/spark/streaming/examples/WordCountHdfs.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/WordCountNetwork.scala (renamed from streaming/src/main/scala/spark/streaming/examples/WordCountNetwork.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/WordCountRaw.scala (renamed from streaming/src/main/scala/spark/streaming/examples/WordCountRaw.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/clickstream/PageViewGenerator.scala (renamed from streaming/src/main/scala/spark/streaming/examples/clickstream/PageViewGenerator.scala) | 0 | ||||
-rw-r--r-- | examples/src/main/scala/spark/streaming/examples/clickstream/PageViewStream.scala (renamed from streaming/src/main/scala/spark/streaming/examples/clickstream/PageViewStream.scala) | 0 | ||||
-rw-r--r-- | project/SparkBuild.scala | 2 |
13 files changed, 1 insertions, 2 deletions
diff --git a/streaming/src/main/scala/spark/streaming/examples/FileStream.scala b/examples/src/main/scala/spark/streaming/examples/FileStream.scala index 81938d30d4..81938d30d4 100644 --- a/streaming/src/main/scala/spark/streaming/examples/FileStream.scala +++ b/examples/src/main/scala/spark/streaming/examples/FileStream.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/FileStreamWithCheckpoint.scala b/examples/src/main/scala/spark/streaming/examples/FileStreamWithCheckpoint.scala index b7bc15a1d5..b7bc15a1d5 100644 --- a/streaming/src/main/scala/spark/streaming/examples/FileStreamWithCheckpoint.scala +++ b/examples/src/main/scala/spark/streaming/examples/FileStreamWithCheckpoint.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/FlumeEventCount.scala b/examples/src/main/scala/spark/streaming/examples/FlumeEventCount.scala index e60ce483a3..e60ce483a3 100644 --- a/streaming/src/main/scala/spark/streaming/examples/FlumeEventCount.scala +++ b/examples/src/main/scala/spark/streaming/examples/FlumeEventCount.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/GrepRaw.scala b/examples/src/main/scala/spark/streaming/examples/GrepRaw.scala index dfaaf03f03..812faa368a 100644 --- a/streaming/src/main/scala/spark/streaming/examples/GrepRaw.scala +++ b/examples/src/main/scala/spark/streaming/examples/GrepRaw.scala @@ -4,7 +4,6 @@ import spark.util.IntParam import spark.storage.StorageLevel import spark.streaming._ -import spark.streaming.StreamingContext._ import spark.streaming.util.RawTextHelper._ object GrepRaw { diff --git a/streaming/src/main/scala/spark/streaming/examples/KafkaWordCount.scala b/examples/src/main/scala/spark/streaming/examples/KafkaWordCount.scala index fe55db6e2c..fe55db6e2c 100644 --- a/streaming/src/main/scala/spark/streaming/examples/KafkaWordCount.scala +++ b/examples/src/main/scala/spark/streaming/examples/KafkaWordCount.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/QueueStream.scala b/examples/src/main/scala/spark/streaming/examples/QueueStream.scala index 2a265d021d..2a265d021d 100644 --- a/streaming/src/main/scala/spark/streaming/examples/QueueStream.scala +++ b/examples/src/main/scala/spark/streaming/examples/QueueStream.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/TopKWordCountRaw.scala b/examples/src/main/scala/spark/streaming/examples/TopKWordCountRaw.scala index 338834bc3c..338834bc3c 100644 --- a/streaming/src/main/scala/spark/streaming/examples/TopKWordCountRaw.scala +++ b/examples/src/main/scala/spark/streaming/examples/TopKWordCountRaw.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/WordCountHdfs.scala b/examples/src/main/scala/spark/streaming/examples/WordCountHdfs.scala index 867a8f42c4..867a8f42c4 100644 --- a/streaming/src/main/scala/spark/streaming/examples/WordCountHdfs.scala +++ b/examples/src/main/scala/spark/streaming/examples/WordCountHdfs.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/WordCountNetwork.scala b/examples/src/main/scala/spark/streaming/examples/WordCountNetwork.scala index eadda60563..eadda60563 100644 --- a/streaming/src/main/scala/spark/streaming/examples/WordCountNetwork.scala +++ b/examples/src/main/scala/spark/streaming/examples/WordCountNetwork.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/WordCountRaw.scala b/examples/src/main/scala/spark/streaming/examples/WordCountRaw.scala index d93335a8ce..d93335a8ce 100644 --- a/streaming/src/main/scala/spark/streaming/examples/WordCountRaw.scala +++ b/examples/src/main/scala/spark/streaming/examples/WordCountRaw.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/clickstream/PageViewGenerator.scala b/examples/src/main/scala/spark/streaming/examples/clickstream/PageViewGenerator.scala index 4c6e08bc74..4c6e08bc74 100644 --- a/streaming/src/main/scala/spark/streaming/examples/clickstream/PageViewGenerator.scala +++ b/examples/src/main/scala/spark/streaming/examples/clickstream/PageViewGenerator.scala diff --git a/streaming/src/main/scala/spark/streaming/examples/clickstream/PageViewStream.scala b/examples/src/main/scala/spark/streaming/examples/clickstream/PageViewStream.scala index a191321d91..a191321d91 100644 --- a/streaming/src/main/scala/spark/streaming/examples/clickstream/PageViewStream.scala +++ b/examples/src/main/scala/spark/streaming/examples/clickstream/PageViewStream.scala diff --git a/project/SparkBuild.scala b/project/SparkBuild.scala index a3f901a081..6ba3026bcc 100644 --- a/project/SparkBuild.scala +++ b/project/SparkBuild.scala @@ -23,7 +23,7 @@ object SparkBuild extends Build { lazy val repl = Project("repl", file("repl"), settings = replSettings) dependsOn (core) - lazy val examples = Project("examples", file("examples"), settings = examplesSettings) dependsOn (core) + lazy val examples = Project("examples", file("examples"), settings = examplesSettings) dependsOn (core) dependsOn (streaming) lazy val bagel = Project("bagel", file("bagel"), settings = bagelSettings) dependsOn (core) |