diff options
| author | Sean Owen <sowen@cloudera.com> | 2014-04-24 10:06:18 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-04-24 10:06:18 -0700 |
| commit | 6338a93f10e8b5f4365f71afd1086bdde64afad5 (patch) | |
| tree | a05692b45940c91b562130eccdf42644e29f8bf1 /streaming | |
| parent | faeb761cbe37521ec7ee6bbab7bcbc4bb1abb328 (diff) | |
| download | spark-6338a93f10e8b5f4365f71afd1086bdde64afad5.tar.gz spark-6338a93f10e8b5f4365f71afd1086bdde64afad5.tar.bz2 spark-6338a93f10e8b5f4365f71afd1086bdde64afad5.zip | |
SPARK-1488. Squash more language feature warnings in new commits by importing implicitConversion
A recent commit reintroduced some of the same warnings that SPARK-1488 resolved. These are just a few more of the same changes to remove these warnings.
Author: Sean Owen <sowen@cloudera.com>
Closes #528 from srowen/SPARK-1488.2 and squashes the following commits:
62d592c [Sean Owen] More feature warnings in tests
4e2e94b [Sean Owen] Squash more language feature warnings in new commits by importing implicitConversion
Diffstat (limited to 'streaming')
6 files changed, 7 insertions, 0 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaInputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaInputDStream.scala index 91f8d342d2..ae5e693df9 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaInputDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaInputDStream.scala @@ -17,6 +17,7 @@ package org.apache.spark.streaming.api.java +import scala.language.implicitConversions import scala.reflect.ClassTag import org.apache.spark.streaming.dstream.InputDStream diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairInputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairInputDStream.scala index add8585308..e6ff8a0cb5 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairInputDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairInputDStream.scala @@ -18,6 +18,8 @@ package org.apache.spark.streaming.api.java import org.apache.spark.streaming.dstream.InputDStream + +import scala.language.implicitConversions import scala.reflect.ClassTag /** diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairReceiverInputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairReceiverInputDStream.scala index 974b3e4516..294bc2be18 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairReceiverInputDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairReceiverInputDStream.scala @@ -17,6 +17,7 @@ package org.apache.spark.streaming.api.java +import scala.language.implicitConversions import scala.reflect.ClassTag import org.apache.spark.streaming.dstream.ReceiverInputDStream diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaReceiverInputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaReceiverInputDStream.scala index 340ef97980..8142dc59ea 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaReceiverInputDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaReceiverInputDStream.scala @@ -17,6 +17,7 @@ package org.apache.spark.streaming.api.java +import scala.language.implicitConversions import scala.reflect.ClassTag import org.apache.spark.streaming.dstream.ReceiverInputDStream diff --git a/streaming/src/test/scala/org/apache/spark/streaming/NetworkReceiverSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/NetworkReceiverSuite.scala index 5c0415ad14..45304c76b0 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/NetworkReceiverSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/NetworkReceiverSuite.scala @@ -20,6 +20,7 @@ package org.apache.spark.streaming import java.nio.ByteBuffer import scala.collection.mutable.ArrayBuffer +import scala.language.postfixOps import org.apache.spark.SparkConf import org.apache.spark.storage.{StorageLevel, StreamBlockId} diff --git a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala index 542c697ae3..458dd3a2b1 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala @@ -20,6 +20,7 @@ package org.apache.spark.streaming import scala.collection.mutable.ArrayBuffer import scala.concurrent.Future import scala.concurrent.ExecutionContext.Implicits.global +import scala.language.postfixOps import org.apache.spark.storage.StorageLevel import org.apache.spark.streaming.dstream.DStream |