From 318bf41158a670e9d62123ea0cb27a833affae24 Mon Sep 17 00:00:00 2001
From: Liwei Lin <proflin.me@gmail.com>
Date: Fri, 26 Feb 2016 00:21:53 -0800
Subject: [PATCH] [MINOR][STREAMING] Fix a minor naming issue in
JavaDStreamLike
Author: Liwei Lin <proflin.me@gmail.com>
Closes #11385 from proflin/Fix-minor-naming.
---
.../org/apache/spark/streaming/api/java/JavaDStreamLike.scala | 2 ++
1 file changed, 2 insertions(+)
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 65aab2fac1..43632f37cc 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)
}
--
GitLab