private Bson renderUnaryComparisonOperator()

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();
        }
    }