Skip to content

Commit

Permalink
fixup
Browse files Browse the repository at this point in the history
  • Loading branch information
zhztheplayer committed Sep 19, 2024
1 parent e3d6c23 commit ccf27b1
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,11 +17,11 @@ import org.apache.spark.sql.execution.joins.{BroadcastHashJoinExec, ShuffledHash
import org.apache.spark.sql.execution.window.WindowExec
import org.apache.spark.sql.types.{ArrayType, MapType, StructType}

class GlabsCostModel extends CostModel[SparkPlan] with Logging {
import GlabsCostModel._
class VeloxCostModel extends CostModel[SparkPlan] with Logging {
import VeloxCostModel._
private val infLongCost = Long.MaxValue

logInfo(s"Created cost model: ${classOf[GlabsCostModel]}")
logInfo(s"Created cost model: ${classOf[VeloxCostModel]}")

override def costOf(node: SparkPlan): GlutenCost = node match {
case _: GroupLeafExec => throw new IllegalStateException()
Expand Down Expand Up @@ -129,6 +129,6 @@ class GlabsCostModel extends CostModel[SparkPlan] with Logging {
override def makeInfCost(): Cost = GlutenCost(infLongCost)
}

object GlabsCostModel {
object VeloxCostModel {
case class GlutenCost(value: Long) extends Cost
}

0 comments on commit ccf27b1

Please sign in to comment.