Simplify conditions

sumeet-db · Apr 16, 2024 · bf000cd · bf000cd
1 parent e0ba7ff
commit bf000cd
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/spark/src/main/scala/org/apache/spark/sql/delta/DeltaHistoryManager.scala b/spark/src/main/scala/org/apache/spark/sql/delta/DeltaHistoryManager.scala
@@ -451,8 +451,7 @@ object DeltaHistoryManager extends DeltaLogging {
     private def queueItemsIfNeeded(): Unit = {
       if (bufferedOutput.isEmpty && bufferedUnderlying.hasNext) {
         val group = new mutable.ArrayBuffer[T]()
-        while (bufferedUnderlying.hasNext &&
-          (!isNewGroupStart(bufferedUnderlying.head) || group.isEmpty)) {
+        while (!bufferedUnderlying.headOption.forall(isNewGroupStart) || group.isEmpty) {
           group += transformItem(bufferedUnderlying.next())
         }
         bufferedOutput = Some(group)