Skip to content

Commit 75adb0b

Browse files
committed
side predicate skip where case
1 parent 2027b41 commit 75adb0b

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

core/src/main/java/com/dtstack/flink/sql/side/SidePredicatesParser.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030
import org.apache.calcite.sql.SqlOperator;
3131
import org.apache.calcite.sql.SqlSelect;
3232
import org.apache.calcite.sql.parser.SqlParseException;
33+
import org.apache.commons.lang3.StringUtils;
3334
import org.apache.flink.table.calcite.FlinkPlannerImpl;
3435

3536
import java.util.List;
@@ -147,6 +148,10 @@ private void fillPredicateInfoToList(SqlBasicCall whereNode, List<PredicateInfo>
147148
String content = (operatorKind == SqlKind.BETWEEN) ? whereNode.getOperands()[conditionIndex].toString() + " AND " +
148149
whereNode.getOperands()[2].toString() : whereNode.getOperands()[conditionIndex].toString();
149150

151+
if (StringUtils.containsIgnoreCase(content,SqlKind.CASE.toString())) {
152+
return;
153+
}
154+
150155
PredicateInfo predicateInfo = PredicateInfo.builder().setOperatorName(operatorName).setOperatorKind(operatorKind.toString())
151156
.setOwnerTable(ownerTable).setFieldName(fieldName).setCondition(content).build();
152157
predicatesInfoList.add(predicateInfo);

0 commit comments

Comments
 (0)