Add parquet methods to release tests

Author: EnricoMi

test-release.scala

@@ -1,12 +1,26 @@
-import uk.co.gresearch.spark.diff._
+import org.apache.spark.sql.DataFrame
+
+def assertSize(df: DataFrame, size: Long): Unit = {
+  df.show()
+  assert(df.collect().size == size)
+}
 
-val left = Seq((1, "one"), (2, "two"), (3, "three")).toDF("id", "value")
-val right = Seq((1, "one"), (2, "Two"), (4, "four")).toDF("id", "value")
 
-val diff = left.diff(right)
-diff.show()
+import uk.co.gresearch.spark.diff._
+import uk.co.gresearch.spark.parquet._
+
+try {
+  val left = Seq((1, "one"), (2, "two"), (3, "three")).toDF("id", "value")
+  val right = Seq((1, "one"), (2, "Two"), (4, "four")).toDF("id", "value")
+  assertSize(left.diff(right), 5)
 
-if (diff.collect().size == 5) { sys.exit(0) }
+  assertSize(spark.read.parquetMetadata("src/test/files/test.parquet"), 5)
+  assertSize(spark.read.parquetMetadata("src/test/files/nested.parquet"), 5)
+  assertSize(spark.read.parquetMetadata("src/test/files/encrypted1.parquet"), 5)
+  assertSize(spark.read.parquetMetadata("src/test/files/encrypted2.parquet"), 5)
+} catch {
+  case e: Throwable => sys.exit(1)
+}
 
-sys.exit(1)
+sys.exit(0)