in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoFilterPushDownVisitor.java [142:157]
private Bson renderUnaryComparisonOperator(
String operator, ResolvedExpression operand, BsonValue value) {
if (operand instanceof FieldReferenceExpression) {
String fieldName = visit((FieldReferenceExpression) operand).getValue();
switch (operator) {
case "$eq":
return Filters.eq(fieldName, value);
case "$ne":
return Filters.ne(fieldName, value);
default:
return Filters.empty();
}
} else {
return Filters.empty();
}
}