[INLONG-11091][Manager] Add in operator

fuweng11 · Sep 13, 2024 · 57429f7 · 57429f7
1 parent fe481bd
commit 57429f7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FilterFunctionUtils.java b/...ager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FilterFunctionUtils.java
@@ -44,6 +44,7 @@
 import org.apache.inlong.sort.protocol.transformation.operator.AndOperator;
 import org.apache.inlong.sort.protocol.transformation.operator.EmptyOperator;
 import org.apache.inlong.sort.protocol.transformation.operator.EqualOperator;
+import org.apache.inlong.sort.protocol.transformation.operator.InOperator;
 import org.apache.inlong.sort.protocol.transformation.operator.IsNotNullOperator;
 import org.apache.inlong.sort.protocol.transformation.operator.IsNullOperator;
 import org.apache.inlong.sort.protocol.transformation.operator.LessThanOperator;
@@ -238,6 +239,8 @@ private static CompareOperator parseCompareOperator(OperationType operationType)
                 return IsNullOperator.getInstance();
             case not_null:
                 return IsNotNullOperator.getInstance();
+            case in:
+                return InOperator.getInstance();
             default:
                 throw new IllegalArgumentException(String.format("Unsupported operateType=%s", operationType));
         }