Update RddDatasetConversion.scala

jleetutorial · web-flow · commit 3836b089ee42 · 2017-09-25T11:10:42.000+01:00
diff --git a/src/main/scala/com/sparkTutorial/sparkSql/RddDatasetConversion.scala b/src/main/scala/com/sparkTutorial/sparkSql/RddDatasetConversion.scala
@@ -36,7 +36,7 @@ object RddDatasetConversion {
     for (response <- responseDataset.rdd.collect()) println(response)
   }
 
-  def toInt(split: String): Option[Int] = {
-    if (split.isEmpty) None else Some(Math.round(split.toFloat))
+  def toInt(split: String): Option[Double] = {
+    if (split.isEmpty) None else Some(split.toDouble)
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ object RddDatasetConversion {`
`36`	`36`	`for (response <- responseDataset.rdd.collect()) println(response)`
`37`	`37`	`}`
`38`	`38`
`39`		`- def toInt(split: String): Option[Int] = {`
`40`		`- if (split.isEmpty) None else Some(Math.round(split.toFloat))`
	`39`	`+ def toInt(split: String): Option[Double] = {`
	`40`	`+ if (split.isEmpty) None else Some(split.toDouble)`
`41`	`41`	`}`
`42`	`42`	`}`