in src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java [125:144]
private static Map<TrinoColumnHandle, Domain> handleAndArguments(
Map<String, ColumnHandle> assignments, Call expression) {
Map<TrinoColumnHandle, Domain> expressionPredicates = new HashMap<>();
expression.getArguments().stream()
.map(argument -> (Call) argument)
.forEach(
argument -> {
if (argument.getFunctionName().equals(EQUAL_OPERATOR_FUNCTION_NAME)) {
expressionPredicates.putAll(
handleExpressionEqualOrIn(assignments, argument, false));
} else if (argument.getFunctionName()
.equals(IN_PREDICATE_FUNCTION_NAME)) {
expressionPredicates.putAll(
handleExpressionEqualOrIn(assignments, argument, true));
}
});
return expressionPredicates;
}