Skip to content

Commit

Permalink
Fix test to supply cols as per new invert method
Browse files Browse the repository at this point in the history
  • Loading branch information
holdenk committed Jul 29, 2015
1 parent 16cc3c3 commit a42d773
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,8 @@ class StringIndexerSuite extends SparkFunSuite with MLlibTestSparkContext {
val expected = Set((0, 0.0), (1, 2.0), (2, 1.0), (3, 0.0), (4, 0.0), (5, 1.0))
assert(output === expected)
// convert reverse our transform
val reversed = indexer.invert().transform(transformed.select("id", "labelIndex"))
val reversed = indexer.invert("labelIndex", "label")
.transform(transformed.select("id", "labelIndex"))
.select("id", "label")
assert(df.collect().map(r => (r.getInt(0), r.getString(1))).toSet ===
reversed.collect().map(r => (r.getInt(0), r.getString(1))).toSet)
Expand Down

0 comments on commit a42d773

Please sign in to comment.