Skip to content

Commit

Permalink
filter transformer get left condition from BaseScanTransformer
Browse files Browse the repository at this point in the history
  • Loading branch information
liujiayi771 committed Nov 25, 2023
1 parent 8a17fb5 commit 8adaf75
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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]
Expand Down

0 comments on commit 8adaf75

Please sign in to comment.