Skip to content

Commit

Permalink
Changes - III addressed
Browse files Browse the repository at this point in the history
  • Loading branch information
chetkhatri committed Jan 1, 2018
1 parent 18d047f commit e891f53
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ public static void main(String[] args) {
.setNumBuckets(3);

Dataset<Row> result = discretizer.fit(df).transform(df);
result.show();
result.show(false);
// $example off$
spark.stop();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ object QuantileDiscretizerExample {
.setNumBuckets(3)

val result = discretizer.fit(df).transform(df)
result.show()
result.show(false)
// $example off$

spark.stop()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,10 +41,10 @@ object StratifiedSamplingExample {
val exactSample = data.sampleByKeyExact(withReplacement = false, fractions = fractions)
// $example off$

println(s"approxSample size is ${approxSample.collect().size.toString}")
println(s"approxSample size is ${approxSample.collect().size}")
approxSample.collect().foreach(println)

println(s"exactSample its size is ${exactSample.collect().size.toString}")
println(s"exactSample its size is ${exactSample.collect().size}")
exactSample.collect().foreach(println)

sc.stop()
Expand Down

0 comments on commit e891f53

Please sign in to comment.