in flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisExpressionVisitor.java [44:83]
public String visit(CallExpression call) {
if (BuiltInFunctionDefinitions.EQUALS.equals(call.getFunctionDefinition())) {
return combineExpression("=", call.getResolvedChildren());
}
if (BuiltInFunctionDefinitions.LESS_THAN.equals(call.getFunctionDefinition())) {
return combineExpression("<", call.getResolvedChildren());
}
if (BuiltInFunctionDefinitions.LESS_THAN_OR_EQUAL.equals(call.getFunctionDefinition())) {
return combineExpression("<=", call.getResolvedChildren());
}
if (BuiltInFunctionDefinitions.GREATER_THAN.equals(call.getFunctionDefinition())) {
return combineExpression(">", call.getResolvedChildren());
}
if (BuiltInFunctionDefinitions.GREATER_THAN_OR_EQUAL.equals(call.getFunctionDefinition())) {
return combineExpression(">=", call.getResolvedChildren());
}
if (BuiltInFunctionDefinitions.NOT_EQUALS.equals(call.getFunctionDefinition())) {
return combineExpression("<>", call.getResolvedChildren());
}
if (BuiltInFunctionDefinitions.OR.equals(call.getFunctionDefinition())) {
return combineExpression("OR", call.getResolvedChildren());
}
if (BuiltInFunctionDefinitions.AND.equals(call.getFunctionDefinition())) {
return combineExpression("AND", call.getResolvedChildren());
}
if (BuiltInFunctionDefinitions.LIKE.equals(call.getFunctionDefinition())) {
return combineExpression("LIKE", call.getResolvedChildren());
}
if (BuiltInFunctionDefinitions.IS_NULL.equals(call.getFunctionDefinition())) {
return combineLeftExpression("IS NULL", call.getResolvedChildren().get(0));
}
if (BuiltInFunctionDefinitions.IS_NOT_NULL.equals(call.getFunctionDefinition())) {
return combineLeftExpression("IS NOT NULL", call.getResolvedChildren().get(0));
}
if (BuiltInFunctionDefinitions.CAST.equals(call.getFunctionDefinition())) {
return call.getChildren().get(0).accept(this);
}
return null;
}