Remove cache checker in logical plan (#3178)

The cache logic will be rewritten at the physical plan layer, using ports as the caching unit. This version is being removed temporarily.
Texera · Dec 30, 2024 · 14572dd · 14572dd
1 parent d85ce7a
commit 14572dd
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 114 deletions.
diff --git a/core/amber/src/main/scala/edu/uci/ics/texera/web/service/WorkflowCacheChecker.scala b/core/amber/src/main/scala/edu/uci/ics/texera/web/service/WorkflowCacheChecker.scala
diff --git a/core/amber/src/main/scala/edu/uci/ics/texera/workflow/LogicalPlan.scala b/core/amber/src/main/scala/edu/uci/ics/texera/workflow/LogicalPlan.scala
@@ -11,7 +11,6 @@ import org.jgrapht.util.SupplierUtil
 
 import java.util
 import scala.collection.mutable.ArrayBuffer
-import scala.jdk.CollectionConverters.SetHasAsScala
 import scala.util.{Failure, Success, Try}
 
 object LogicalPlan {
@@ -65,14 +64,6 @@ case class LogicalPlan(
       .filter(op => jgraphtDag.outDegreeOf(op) == 0)
       .toList
 
-  def getUpstreamOps(opId: OperatorIdentity): List[LogicalOp] = {
-    jgraphtDag
-      .incomingEdgesOf(opId)
-      .asScala
-      .map(e => operatorMap(e.fromOpId))
-      .toList
-  }
-
   def getUpstreamLinks(opId: OperatorIdentity): List[LogicalLink] = {
     links.filter(l => l.toOpId == opId)
   }