ch08 correction

spark-in-action · Dec 11, 2015 · 7c3c430 · 7c3c430
1 parent 234de3f
commit 7c3c430
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/ch08/scala/ch08-listings.scala b/ch08/scala/ch08-listings.scala
@@ -62,7 +62,8 @@ dfraw.show()
 
 dfraw.groupBy(dfraw("workclass")).count().foreach(println)
 //Missing data imputation
-val dfrawrpl = dfraw.na.replace(Array("workclass", "occupation"), Map("?" -> "Private"))
+val dfrawrp = dfraw.na.replace(Array("workclass"), Map("?" -> "Private"))
+val dfrawrpl = dfrawrp.na.replace(Array("occupation"), Map("?" -> "Prof-specialty"))
 val dfrawnona = dfrawrpl.na.replace(Array("native_country"), Map("?" -> "United-States"))
 
 //converting strings to numeric values