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 7d6daa1 commit 33c5bccCopy full SHA for 33c5bcc
sql/core/src/test/scala/org/apache/spark/sql/QueryTest.scala
@@ -341,14 +341,10 @@ object QueryTest {
341
case (a: Array[_], b: Array[_]) =>
342
a.length == b.length && a.zip(b).forall { case (l, r) => compare(l, r)}
343
case (a: Map[_, _], b: Map[_, _]) =>
344
- if (a.size == b.size && a.size > 0) {
345
- a.keys.map { aKey =>
+ a.size == b.size && a.keys.forall { aKey =>
346
b.keys.find(bKey => compare(aKey, bKey))
347
.map(bKey => compare(a(aKey), b(bKey)))
348
.getOrElse(false)
349
- }.reduce(_ && _)
350
- } else {
351
- a.size == b.size
352
}
353
case (a: Iterable[_], b: Iterable[_]) =>
354
a.size == b.size && a.zip(b).forall { case (l, r) => compare(l, r)}
0 commit comments