Skip to content

Commit

Permalink
Fix ConvertToQbeast test
Browse files Browse the repository at this point in the history
  • Loading branch information
osopardo1 authored and osopardo1 committed Feb 17, 2023
1 parent 878abb4 commit 40fddf4
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ class ConvertToQbeastTest extends QbeastIntegrationTestSpec with PrivateMethodTe
val sourceDf = spark.read.format(fileFormat).load(tmpDir)
val qbeastDf = spark.read.format("qbeast").load(tmpDir)

assertLargeDatasetEquality(qbeastDf, sourceDf)
assertLargeDatasetEquality(qbeastDf, sourceDf, orderedComparison = false)

// All non-qbeast files are considered staging files and are placed
// directly into the staging revision(RevisionID = 0)
Expand All @@ -76,7 +76,7 @@ class ConvertToQbeastTest extends QbeastIntegrationTestSpec with PrivateMethodTe
val sourceDf = spark.read.format(fileFormat).load(tmpDir)
val qbeastDf = spark.read.format("qbeast").load(tmpDir)

assertLargeDatasetEquality(qbeastDf, sourceDf)
assertLargeDatasetEquality(qbeastDf, sourceDf, orderedComparison = false)

// All non-qbeast files are considered staging files and are placed
// directly into the staging revision(RevisionID = 0)
Expand Down Expand Up @@ -226,7 +226,7 @@ class ConvertToQbeastTest extends QbeastIntegrationTestSpec with PrivateMethodTe
// Compare DataFrames
val sourceDf = spark.read.format(fileFormat).load(tmpDir)
val qbeastDf = spark.read.format("qbeast").load(tmpDir)
assertLargeDatasetEquality(qbeastDf, sourceDf)
assertLargeDatasetEquality(qbeastDf, sourceDf, orderedComparison = false)

// Standard staging revision behavior
val qs = getQbeastSnapshot(spark, tmpDir)
Expand Down

0 comments on commit 40fddf4

Please sign in to comment.