Skip to content

Commit 8d92d93

Browse files
srowenpwendell
authored andcommitted
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 <[email protected]> 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 (cherry picked from commit 6338a93) Signed-off-by: Patrick Wendell <[email protected]>
1 parent 563be2f commit 8d92d93

File tree

6 files changed

+7
-0
lines changed

6 files changed

+7
-0
lines changed

streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaInputDStream.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
package org.apache.spark.streaming.api.java
1919

20+
import scala.language.implicitConversions
2021
import scala.reflect.ClassTag
2122

2223
import org.apache.spark.streaming.dstream.InputDStream

streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairInputDStream.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,8 @@
1818
package org.apache.spark.streaming.api.java
1919

2020
import org.apache.spark.streaming.dstream.InputDStream
21+
22+
import scala.language.implicitConversions
2123
import scala.reflect.ClassTag
2224

2325
/**

streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairReceiverInputDStream.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
package org.apache.spark.streaming.api.java
1919

20+
import scala.language.implicitConversions
2021
import scala.reflect.ClassTag
2122

2223
import org.apache.spark.streaming.dstream.ReceiverInputDStream

streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaReceiverInputDStream.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
package org.apache.spark.streaming.api.java
1919

20+
import scala.language.implicitConversions
2021
import scala.reflect.ClassTag
2122

2223
import org.apache.spark.streaming.dstream.ReceiverInputDStream

streaming/src/test/scala/org/apache/spark/streaming/NetworkReceiverSuite.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ package org.apache.spark.streaming
2020
import java.nio.ByteBuffer
2121

2222
import scala.collection.mutable.ArrayBuffer
23+
import scala.language.postfixOps
2324

2425
import org.apache.spark.SparkConf
2526
import org.apache.spark.storage.{StorageLevel, StreamBlockId}

streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ package org.apache.spark.streaming
2020
import scala.collection.mutable.ArrayBuffer
2121
import scala.concurrent.Future
2222
import scala.concurrent.ExecutionContext.Implicits.global
23+
import scala.language.postfixOps
2324

2425
import org.apache.spark.storage.StorageLevel
2526
import org.apache.spark.streaming.dstream.DStream

0 commit comments

Comments
 (0)