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
}
}