Unapply change

wzheng · wzheng · commit 24d55f3caa05 · 2020-12-03T21:22:03.000Z
diff --git a/src/test/scala/edu/berkeley/cs/rise/opaque/OpaqueOperatorTests.scala b/src/test/scala/edu/berkeley/cs/rise/opaque/OpaqueOperatorTests.scala
@@ -339,8 +339,8 @@ trait OpaqueOperatorTests extends FunSuite with BeforeAndAfterAll { self =>
     val data = for (i <- 0 until 256) yield (i, abc(i), i.toDouble)
     val words = makeDF(data, securityLevel, "id", "category", "price")
 
-    val result = words.groupBy("category").agg(avg("price"))
-    result.collect.sortBy { case Row(category: String, _) => category }
+    words.groupBy("category").agg(avg("price").as("avgPrice"))
+      .collect.sortBy { case Row(category: String, _) => category }
   }
 
   testAgainstSpark("aggregate count") { securityLevel =>

Original file line number	Diff line number	Diff line change
`@@ -339,8 +339,8 @@ trait OpaqueOperatorTests extends FunSuite with BeforeAndAfterAll { self =>`
`339`	`339`	`val data = for (i <- 0 until 256) yield (i, abc(i), i.toDouble)`
`340`	`340`	`val words = makeDF(data, securityLevel, "id", "category", "price")`
`341`	`341`
`342`		`- val result = words.groupBy("category").agg(avg("price"))`
`343`		`- result.collect.sortBy { case Row(category: String, _) => category }`
	`342`	`+ words.groupBy("category").agg(avg("price").as("avgPrice"))`
	`343`	`+ .collect.sortBy { case Row(category: String, _) => category }`
`344`	`344`	`}`
`345`	`345`
`346`	`346`	`testAgainstSpark("aggregate count") { securityLevel =>`