aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/test
diff options
context:
space:
mode:
authorSean Owen <sowen@cloudera.com>2014-04-24 10:06:18 -0700
committerPatrick Wendell <pwendell@gmail.com>2014-04-24 10:06:18 -0700
commit6338a93f10e8b5f4365f71afd1086bdde64afad5 (patch)
treea05692b45940c91b562130eccdf42644e29f8bf1 /streaming/src/test
parentfaeb761cbe37521ec7ee6bbab7bcbc4bb1abb328 (diff)
downloadspark-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/src/test')
-rw-r--r--streaming/src/test/scala/org/apache/spark/streaming/NetworkReceiverSuite.scala1
-rw-r--r--streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala1
2 files changed, 2 insertions, 0 deletions
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