Skip to content

Commit

Permalink
Update README.md (#48)
Browse files Browse the repository at this point in the history
  • Loading branch information
Yuan Zhao authored and MrPowers committed Mar 13, 2019
1 parent 17f11ae commit 446c83a
Showing 1 changed file with 16 additions and 16 deletions.
32 changes: 16 additions & 16 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -117,34 +117,34 @@ trait SparkSessionTestWrapper {
The `DatasetComparer` trait defines the `assertSmallDatasetEquality` method. Extend your spec file with the `SparkSessionTestWrapper` trait to create DataFrames and the `DatasetComparer` trait to make DataFrame comparisons.

```scala
import org.apache.spark.sql.types._
import org.apache.spark.sql.Row
import org.apache.spark.sql.functions._
import com.github.mrpowers.spark.fast.tests.DatasetComparer

class DatasetSpec extends FunSpec with SparkSessionTestWrapper with DatasetComparer {

import spark.implicits._

it("aliases a DataFrame") {
it("aliases a DataFrame") {

val sourceDF = Seq(
("jose"),
("li"),
("luisa")
).toDF("name")
val sourceDF = Seq(
("jose"),
("li"),
("luisa")
).toDF("name")

val actualDF = sourceDF.select(col("name").alias("student"))
val actualDF = sourceDF.select(col("name").alias("student"))

val expectedDF = Seq(
("jose"),
("li"),
("luisa")
).toDF("student")
val expectedDF = Seq(
("jose"),
("li"),
("luisa")
).toDF("student")

assertSmallDatasetEquality(actualDF, expectedDF)

}
assertSmallDatasetEquality(actualDF, expectedDF)

}

}
```

Expand Down

0 comments on commit 446c83a

Please sign in to comment.