Update UnionLogsSolution.scala

jleetutorial · web-flow · commit e425807c72c2 · 2017-09-19T22:47:40.000+01:00
diff --git a/src/main/scala/com/sparkTutorial/rdd/nasaApacheWebLogs/UnionLogsSolution.scala b/src/main/scala/com/sparkTutorial/rdd/nasaApacheWebLogs/UnionLogsSolution.scala
@@ -17,7 +17,7 @@ object UnionLogsSolution extends Serializable {
 
     val cleanLogLines = aggregatedLogLines.filter(line => isNotHeader(line))
 
-    val sample = cleanLogLines.sample(true, 0.1)
+    val sample = cleanLogLines.sample(withReplacement = true, fraction = 0.1)
 
     sample.saveAsTextFile("out/sample_nasa_logs.csv")
   }

Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ object UnionLogsSolution extends Serializable {`
`17`	`17`
`18`	`18`	`val cleanLogLines = aggregatedLogLines.filter(line => isNotHeader(line))`
`19`	`19`
`20`		`- val sample = cleanLogLines.sample(true, 0.1)`
	`20`	`+ val sample = cleanLogLines.sample(withReplacement = true, fraction = 0.1)`
`21`	`21`
`22`	`22`	`sample.saveAsTextFile("out/sample_nasa_logs.csv")`
`23`	`23`	`}`