Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
zml1206 committed Dec 10, 2024
1 parent bdf62b7 commit c4a7368
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,9 @@ abstract class BatchScanExecTransformerBase(
ExpressionConverter.replaceAttributeReference(expr),
output)
}
case _ => Seq.empty
case _ =>
logInfo(s"${scan.getClass.toString} does not support push down filters")
Seq.empty
}

def setPushDownFilters(filters: Seq[Expression]): Unit = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,12 +58,13 @@ object ExpressionConverter extends SQLConfHelper with Logging {
def canReplaceWithExpressionTransformer(
expr: Expression,
attributeSeq: Seq[Attribute]): Boolean = {
val expressionsMap = ExpressionMappings.expressionsMap
try {
replaceWithExpressionTransformer0(expr, attributeSeq, expressionsMap)
replaceWithExpressionTransformer(expr, attributeSeq)
true
} catch {
case _: Exception => false
case e: Exception =>
logInfo(e.getMessage)
false
}
}

Expand Down

0 comments on commit c4a7368

Please sign in to comment.