You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/04/24 19:06:37 UTC
git commit: SPARK-1488. Squash more language feature warnings in new
commits by importing implicitConversion
Repository: spark
Updated Branches:
refs/heads/master faeb761cb -> 6338a93f1
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 <so...@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
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/6338a93f
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/6338a93f
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/6338a93f
Branch: refs/heads/master
Commit: 6338a93f10e8b5f4365f71afd1086bdde64afad5
Parents: faeb761
Author: Sean Owen <so...@cloudera.com>
Authored: Thu Apr 24 10:06:18 2014 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Thu Apr 24 10:06:18 2014 -0700
----------------------------------------------------------------------
.../org/apache/spark/streaming/api/java/JavaInputDStream.scala | 1 +
.../org/apache/spark/streaming/api/java/JavaPairInputDStream.scala | 2 ++
.../spark/streaming/api/java/JavaPairReceiverInputDStream.scala | 1 +
.../apache/spark/streaming/api/java/JavaReceiverInputDStream.scala | 1 +
.../scala/org/apache/spark/streaming/NetworkReceiverSuite.scala | 1 +
.../scala/org/apache/spark/streaming/StreamingListenerSuite.scala | 1 +
6 files changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/6338a93f/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaInputDStream.scala
----------------------------------------------------------------------
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 91f8d34..ae5e693 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
http://git-wip-us.apache.org/repos/asf/spark/blob/6338a93f/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairInputDStream.scala
----------------------------------------------------------------------
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 add8585..e6ff8a0 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
/**
http://git-wip-us.apache.org/repos/asf/spark/blob/6338a93f/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairReceiverInputDStream.scala
----------------------------------------------------------------------
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 974b3e4..294bc2b 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
http://git-wip-us.apache.org/repos/asf/spark/blob/6338a93f/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaReceiverInputDStream.scala
----------------------------------------------------------------------
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 340ef97..8142dc5 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
http://git-wip-us.apache.org/repos/asf/spark/blob/6338a93f/streaming/src/test/scala/org/apache/spark/streaming/NetworkReceiverSuite.scala
----------------------------------------------------------------------
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 5c0415a..45304c7 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}
http://git-wip-us.apache.org/repos/asf/spark/blob/6338a93f/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala
----------------------------------------------------------------------
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 542c697..458dd3a 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