Refactor window operations to do them in the exec (#2882)

Signed-off-by: Robert (Bobby) Evans <bobby@apache.org>
NVIDIA · Jul 7, 2021 · 3410f68 · 3410f68
1 parent cd1481d
commit 3410f68
Show file tree

Hide file tree

Showing 3 changed files with 558 additions and 456 deletions.
diff --git a/sql-plugin/src/main/scala/com/nvidia/spark/rapids/Arm.scala b/sql-plugin/src/main/scala/com/nvidia/spark/rapids/Arm.scala
@@ -74,6 +74,8 @@ trait Arm {
     } finally {
       r match {
         case c: AutoCloseable => c.close()
+        case scala.util.Left(c: AutoCloseable) => c.close()
+        case scala.util.Right(c: AutoCloseable) => c.close()
         case _ => //NOOP
       }
     }