diff options
| author | Denny <dennybritz@gmail.com> | 2012-11-13 13:15:32 -0800 |
|---|---|---|
| committer | Denny <dennybritz@gmail.com> | 2012-11-13 13:15:32 -0800 |
| commit | b6f7ba813e93916dad9dbb0f06819362a5fb7cf7 (patch) | |
| tree | a420f0c4f3fe47abe13295b04ecee3f7aef259a5 /streaming | |
| parent | 255b3e44c18e64a55afb184f39746780b391a496 (diff) | |
| download | spark-b6f7ba813e93916dad9dbb0f06819362a5fb7cf7.tar.gz spark-b6f7ba813e93916dad9dbb0f06819362a5fb7cf7.tar.bz2 spark-b6f7ba813e93916dad9dbb0f06819362a5fb7cf7.zip | |
change import for example function
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/examples/KafkaWordCount.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/examples/KafkaWordCount.scala b/streaming/src/main/scala/spark/streaming/examples/KafkaWordCount.scala index 1e92cbb210..c85ac8e984 100644 --- a/streaming/src/main/scala/spark/streaming/examples/KafkaWordCount.scala +++ b/streaming/src/main/scala/spark/streaming/examples/KafkaWordCount.scala @@ -3,7 +3,7 @@ package spark.streaming.examples import spark.streaming._ import spark.streaming.StreamingContext._ import spark.storage.StorageLevel -import WordCount2_ExtraFunctions._ +import spark.streaming.util.RawTextHelper._ object KafkaWordCount { def main(args: Array[String]) { |