aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTathagata Das <tathagata.das1565@gmail.com>2013-01-06 19:31:54 -0800
committerTathagata Das <tathagata.das1565@gmail.com>2013-01-06 19:31:54 -0800
commitaf8738dfb592eb37d4d6c91e42624e844d4e493b (patch)
treee9996686a339fec90eef4e98009cbbc0a8a23606
parent934ecc829aa06ce4d9ded3596b86b4733ed2a123 (diff)
downloadspark-af8738dfb592eb37d4d6c91e42624e844d4e493b.tar.gz
spark-af8738dfb592eb37d4d6c91e42624e844d4e493b.tar.bz2
spark-af8738dfb592eb37d4d6c91e42624e844d4e493b.zip
Moved Spark Streaming examples to examples sub-project.
-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.scala2
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)