Update the return type to JavaRDD[T]

zsxwing · zsxwing · commit b36993fc5361 · 2015-06-15T21:07:57.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala b/core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala
@@ -426,8 +426,8 @@ private[spark] object PythonRDD extends Logging {
   }
 
   /** Create an RDD that has no partitions or elements. */
-  def emptyRDD[T](sc: JavaSparkContext): JavaRDD[Array[Byte]] = {
-    sc.emptyRDD[Array[Byte]]
+  def emptyRDD[T](sc: JavaSparkContext): JavaRDD[T] = {
+    sc.emptyRDD[T]
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -426,8 +426,8 @@ private[spark] object PythonRDD extends Logging {`
`426`	`426`	`}`
`427`	`427`
`428`	`428`	`/** Create an RDD that has no partitions or elements. */`
`429`		`- def emptyRDD[T](sc: JavaSparkContext): JavaRDD[Array[Byte]] = {`
`430`		`- sc.emptyRDD[Array[Byte]]`
	`429`	`+ def emptyRDD[T](sc: JavaSparkContext): JavaRDD[T] = {`
	`430`	`+ sc.emptyRDD[T]`
`431`	`431`	`}`
`432`	`432`
`433`	`433`	`/**`