We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4d7ef2e commit eb40036Copy full SHA for eb40036
core/src/main/scala/org/apache/spark/api/python/PythonRDD.scala
@@ -349,9 +349,7 @@ private[spark] object PythonRDD extends Logging {
349
rdd
350
}
351
352
- // **** //
353
-
354
- def writeToStream(elem: Any, dataOut: DataOutputStream)(implicit m: ClassManifest[Any]) {
+ def writeToStream(elem: Any, dataOut: DataOutputStream) {
355
elem match {
356
case bytes: Array[Byte] =>
357
dataOut.writeInt(bytes.length)
0 commit comments