From 8adaf7504a7b50f960f0fc4f6ca487fec2c3ccaa Mon Sep 17 00:00:00 2001 From: "joey.ljy" Date: Sat, 25 Nov 2023 08:29:31 +0800 Subject: [PATCH] filter transformer get left condition from BaseScanTransformer --- .../io/glutenproject/execution/FilterExecTransformer.scala | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/backends-velox/src/main/scala/io/glutenproject/execution/FilterExecTransformer.scala b/backends-velox/src/main/scala/io/glutenproject/execution/FilterExecTransformer.scala index 9b1aba47803d..814ffd1075c7 100644 --- a/backends-velox/src/main/scala/io/glutenproject/execution/FilterExecTransformer.scala +++ b/backends-velox/src/main/scala/io/glutenproject/execution/FilterExecTransformer.scala @@ -95,10 +95,8 @@ case class FilterExecTransformer(condition: Expression, child: SparkPlan) private def getLeftCondition: Expression = { val scanFilters = child match { // Get the filters including the manually pushed down ones. - case batchScanTransformer: BatchScanTransformer => - batchScanTransformer.filterExprs() - case fileScanTransformer: FileSourceScanTransformer => - fileScanTransformer.filterExprs() + case baseScanTransformer: BaseScanTransformer => + baseScanTransformer.filterExprs() // For fallback scan, we need to keep original filter. case _ => Seq.empty[Expression]