From 692bd7249e59b8a787f491946a843ba035746bf8 Mon Sep 17 00:00:00 2001 From: Sun Rui Date: Wed, 8 Jul 2015 21:48:06 +0800 Subject: [PATCH] [SPARK-8897][SPARKR] SparkR DataFrame fail to return data of float type. --- core/src/main/scala/org/apache/spark/api/r/SerDe.scala | 3 +++ 1 file changed, 3 insertions(+) diff --git a/core/src/main/scala/org/apache/spark/api/r/SerDe.scala b/core/src/main/scala/org/apache/spark/api/r/SerDe.scala index 56adc857d4ce..0d88067af497 100644 --- a/core/src/main/scala/org/apache/spark/api/r/SerDe.scala +++ b/core/src/main/scala/org/apache/spark/api/r/SerDe.scala @@ -215,6 +215,9 @@ private[spark] object SerDe { case "long" | "java.lang.Long" => writeType(dos, "double") writeDouble(dos, value.asInstanceOf[Long].toDouble) + case "float" | "java.lang.Float" => + writeType(dos, "double") + writeDouble(dos, value.asInstanceOf[Float].toDouble) case "double" | "java.lang.Double" => writeType(dos, "double") writeDouble(dos, value.asInstanceOf[Double])