You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2016/02/26 09:21:55 UTC
spark git commit: [MINOR][STREAMING] Fix a minor naming issue in
JavaDStreamLike
Repository: spark
Updated Branches:
refs/heads/master 9812a24aa -> 318bf4115
[MINOR][STREAMING] Fix a minor naming issue in JavaDStreamLike
Author: Liwei Lin <pr...@gmail.com>
Closes #11385 from proflin/Fix-minor-naming.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/318bf411
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/318bf411
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/318bf411
Branch: refs/heads/master
Commit: 318bf41158a670e9d62123ea0cb27a833affae24
Parents: 9812a24
Author: Liwei Lin <pr...@gmail.com>
Authored: Fri Feb 26 00:21:53 2016 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Fri Feb 26 00:21:53 2016 -0800
----------------------------------------------------------------------
.../org/apache/spark/streaming/api/java/JavaDStreamLike.scala | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/318bf411/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala
----------------------------------------------------------------------
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala
index 65aab2f..43632f3 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaDStreamLike.scala
@@ -50,6 +50,8 @@ trait JavaDStreamLike[T, This <: JavaDStreamLike[T, This, R], R <: JavaRDDLike[T
def wrapRDD(in: RDD[T]): R
+ // This is just unfortunate we made a mistake in naming -- should be scalaLongToJavaLong.
+ // Don't fix this for now as it would break binary compatibility.
implicit def scalaIntToJavaLong(in: DStream[Long]): JavaDStream[jl.Long] = {
in.map(jl.Long.valueOf)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org