Skip to content
Snippets Groups Projects
Commit 318bf411 authored by Liwei Lin's avatar Liwei Lin Committed by Reynold Xin
Browse files

[MINOR][STREAMING] Fix a minor naming issue in JavaDStreamLike

Author: Liwei Lin <proflin.me@gmail.com>

Closes #11385 from proflin/Fix-minor-naming.
parent 9812a24a
No related branches found
No related tags found
No related merge requests found
......@@ -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)
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment