diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2014-11-25 15:27:20 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-11-25 15:27:20 -0800 |
| commit | a2c01ae5e3489b6c21a4c7bcc1ec615069ff4829 (patch) | |
| tree | 0fe489ef3cf54f7491f6de23e2ad9061d022df2e /streaming | |
| parent | a9944c809017cc61c9c2e38efe9d709dfb0a94cd (diff) | |
| download | spark-a2c01ae5e3489b6c21a4c7bcc1ec615069ff4829.tar.gz spark-a2c01ae5e3489b6c21a4c7bcc1ec615069ff4829.tar.bz2 spark-a2c01ae5e3489b6c21a4c7bcc1ec615069ff4829.zip | |
[HOTFIX] Fixing broken build due to missing imports.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala index 806fe5f83e..a4b5ae4a55 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala @@ -26,6 +26,7 @@ import org.apache.hadoop.mapreduce.{OutputFormat => NewOutputFormat} import org.apache.spark.{HashPartitioner, Partitioner, SerializableWritable} import org.apache.spark.rdd.RDD +import org.apache.spark.SparkContext._ import org.apache.spark.streaming.{Duration, Time} import org.apache.spark.streaming.StreamingContext._ |