Skip to content

Commit

Permalink
[VL] Code clean for BasicPhysicalOperatorTransformer (#7695)
Browse files Browse the repository at this point in the history
  • Loading branch information
zml1206 authored Oct 29, 2024
1 parent eca61bd commit 8324a88
Showing 1 changed file with 6 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ abstract class FilterExecTransformerBase(val cond: Expression, val input: SparkP
BackendsApiManager.getMetricsApiInstance.genFilterTransformerMetrics(sparkContext)

// Split out all the IsNotNulls from condition.
private val (notNullPreds, otherPreds) = splitConjunctivePredicates(cond).partition {
private val (notNullPreds, _) = splitConjunctivePredicates(cond).partition {
case IsNotNull(a) => isNullIntolerant(a) && a.references.subsetOf(child.outputSet)
case _ => false
}
Expand Down Expand Up @@ -170,14 +170,6 @@ abstract class FilterExecTransformerBase(val cond: Expression, val input: SparkP
}
}

object FilterExecTransformerBase {
implicit class FilterExecTransformerBaseImplicits(filter: FilterExecTransformerBase) {
def isNoop(): Boolean = {
filter.getRemainingCondition == null
}
}
}

abstract class ProjectExecTransformerBase(val list: Seq[NamedExpression], val input: SparkPlan)
extends UnaryTransformSupport
with OrderPreservingNodeShim
Expand Down Expand Up @@ -265,13 +257,11 @@ abstract class ProjectExecTransformerBase(val list: Seq[NamedExpression], val in

// An alternatives for UnionExec.
case class ColumnarUnionExec(children: Seq[SparkPlan]) extends GlutenPlan {
children.foreach(
child =>
child match {
case w: WholeStageTransformer =>
w.setOutputSchemaForPlan(output)
case _ =>
})
children.foreach {
case w: WholeStageTransformer =>
w.setOutputSchemaForPlan(output)
case _ =>
}

override def supportsColumnar: Boolean = true

Expand Down

0 comments on commit 8324a88

Please sign in to comment.