This is an automated email from the ASF dual-hosted git repository.

aglinxinyuan pushed a commit to branch xinyuan-scheduler-jump
in repository https://gitbox.apache.org/repos/asf/texera.git


The following commit(s) were added to refs/heads/xinyuan-scheduler-jump by this 
push:
     new 0f55e3705e refactor(amber): rename Schedule cursor to currentLevel
0f55e3705e is described below

commit 0f55e3705eec931c661dbae39afc2d0ece01cdb6
Author: Xinyuan Lin <[email protected]>
AuthorDate: Fri May 1 17:09:46 2026 -0700

    refactor(amber): rename Schedule cursor to currentLevel
    
    Drop the redundant `Index` suffix from the cursor field. Level keys are
    0..N-1 by construction, so the cursor value is the level itself.
    
    Co-Authored-By: Claude Opus 4.7 (1M context) <[email protected]>
---
 .../texera/amber/engine/architecture/scheduling/Schedule.scala    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/Schedule.scala
 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/Schedule.scala
index be0acba484..909d96ef60 100644
--- 
a/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/Schedule.scala
+++ 
b/amber/src/main/scala/org/apache/texera/amber/engine/architecture/scheduling/Schedule.scala
@@ -36,17 +36,17 @@ case class Schedule(
         regions.iterator.flatMap(region => 
region.getOperators.map(_.id.logicalOpId -> level))
     }.toMap
 
-  private var currentLevelIndex: Int = initialLevelIndex
+  private var currentLevel: Int = initialLevelIndex
 
   def getRegions: List[Region] = levelSets.values.flatten.toList
 
   def getLevelIndexOfOperator(opId: OperatorIdentity): Option[Int] = 
operatorLevelIndices.get(opId)
 
-  override def hasNext: Boolean = currentLevelIndex < levelSets.size
+  override def hasNext: Boolean = currentLevel < levelSets.size
 
   override def next(): Set[Region] = {
-    val regions = levelSets.getOrElse(currentLevelIndex, Set.empty)
-    currentLevelIndex += 1
+    val regions = levelSets.getOrElse(currentLevel, Set.empty)
+    currentLevel += 1
     regions
   }
 }

Reply via email to