We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 60c4917 commit e713b24Copy full SHA for e713b24
core/src/test/scala/org/locationtech/rasterframes/TestEnvironment.scala
@@ -62,9 +62,9 @@ trait TestEnvironment extends FunSpec with GeoTrellisTestEnvironment
62
val dest = Files.createTempFile(Paths.get(outputLocalPath), "rf", ".parquet")
63
logger.trace(s"Writing '${sanitized.columns.mkString(", ")}' to '$dest'...")
64
sanitized.write.mode(SaveMode.Overwrite).parquet(dest.toString)
65
- val rows = df.sparkSession.read.parquet(dest.toString).count()
+ val rows = df.sparkSession.read.parquet(dest.toString).collect()
66
logger.trace(s" read back $rows row(s)")
67
- rows == inRows
+ rows.length == inRows
68
}
69
70
/**
0 commit comments