in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoFilterPushDownVisitor.java [240:248]
private static <T> Optional<T> extractExpression(
List<ResolvedExpression> expressions, Class<T> type) {
for (ResolvedExpression expression : expressions) {
if (type.isAssignableFrom(expression.getClass())) {
return Optional.of(type.cast(expression));
}
}
return Optional.empty();
}