fix: add AbstractFunctionTestBases

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/collection/AbstractFunctionCollectionTestBase.java

@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.inlong.sdk.transform.process.function.collection;
+
+import org.apache.inlong.sdk.transform.pojo.CsvSourceInfo;
+import org.apache.inlong.sdk.transform.pojo.FieldInfo;
+import org.apache.inlong.sdk.transform.pojo.KvSinkInfo;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * AbstractFunctionStringTestBase
+ * description: define static parameters for StringFunction tests
+ */
+public abstract class AbstractFunctionCollectionTestBase {
+
+    protected static final List<FieldInfo> srcFields = new ArrayList<>();
+    protected static final List<FieldInfo> dstFields = new ArrayList<>();
+    protected static final CsvSourceInfo csvSource;
+    protected static final KvSinkInfo kvSink;
+
+    static {
+        for (int i = 1; i < 4; i++) {
+            FieldInfo field = new FieldInfo();
+            field.setName("string" + i);
+            srcFields.add(field);
+        }
+        for (int i = 1; i < 4; i++) {
+            FieldInfo field = new FieldInfo();
+            field.setName("numeric" + i);
+            srcFields.add(field);
+        }
+        FieldInfo field = new FieldInfo();
+        field.setName("result");
+        dstFields.add(field);
+        csvSource = new CsvSourceInfo("UTF-8", '|', '\\', srcFields);
+        kvSink = new KvSinkInfo("UTF-8", dstFields);
+    }
+}

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/collection/TestArrayFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestArrayFunction extends AbstractFunctionStringTestBase {
+public class TestArrayFunction extends AbstractFunctionCollectionTestBase {
 
     @Test
     public void testArrayFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/collection/TestFindInSetFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestFindInSetFunction extends AbstractFunctionStringTestBase {
+public class TestFindInSetFunction extends AbstractFunctionCollectionTestBase {
 
     @Test
     public void testFindInSetFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/collection/TestMapEntriesFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestMapEntriesFunction extends AbstractFunctionStringTestBase {
+public class TestMapEntriesFunction extends AbstractFunctionCollectionTestBase {
 
     @Test
     public void testMapEntriesFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/collection/TestMapFromArraysFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestMapFromArraysFunction extends AbstractFunctionStringTestBase {
+public class TestMapFromArraysFunction extends AbstractFunctionCollectionTestBase {
 
     @Test
     public void testMapFromArraysFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/collection/TestMapFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestMapFunction extends AbstractFunctionStringTestBase {
+public class TestMapFunction extends AbstractFunctionCollectionTestBase {
 
     @Test
     public void testMapFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/collection/TestMapKeysFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestMapKeysFunction extends AbstractFunctionStringTestBase {
+public class TestMapKeysFunction extends AbstractFunctionCollectionTestBase {
 
     @Test
     public void testMapKeysFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/collection/TestMapUnionFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestMapUnionFunction extends AbstractFunctionStringTestBase {
+public class TestMapUnionFunction extends AbstractFunctionCollectionTestBase {
 
     @Test
     public void testMapUnionFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/collection/TestMapValuesFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestMapValuesFunction extends AbstractFunctionStringTestBase {
+public class TestMapValuesFunction extends AbstractFunctionCollectionTestBase {
 
     @Test
     public void testMapValuesFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/compression/AbstractFunctionCompressionTestBase.java

@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.inlong.sdk.transform.process.function.compression;
+
+import org.apache.inlong.sdk.transform.pojo.CsvSourceInfo;
+import org.apache.inlong.sdk.transform.pojo.FieldInfo;
+import org.apache.inlong.sdk.transform.pojo.KvSinkInfo;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * AbstractFunctionStringTestBase
+ * description: define static parameters for StringFunction tests
+ */
+public abstract class AbstractFunctionCompressionTestBase {
+
+    protected static final List<FieldInfo> srcFields = new ArrayList<>();
+    protected static final List<FieldInfo> dstFields = new ArrayList<>();
+    protected static final CsvSourceInfo csvSource;
+    protected static final KvSinkInfo kvSink;
+
+    static {
+        for (int i = 1; i < 4; i++) {
+            FieldInfo field = new FieldInfo();
+            field.setName("string" + i);
+            srcFields.add(field);
+        }
+        for (int i = 1; i < 4; i++) {
+            FieldInfo field = new FieldInfo();
+            field.setName("numeric" + i);
+            srcFields.add(field);
+        }
+        FieldInfo field = new FieldInfo();
+        field.setName("result");
+        dstFields.add(field);
+        csvSource = new CsvSourceInfo("UTF-8", '|', '\\', srcFields);
+        kvSink = new KvSinkInfo("UTF-8", dstFields);
+    }
+}

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/compression/TestCompressFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestCompressFunction extends AbstractFunctionStringTestBase {
+public class TestCompressFunction extends AbstractFunctionCompressionTestBase {
 
     @Test
     public void testCompressFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/compression/TestUnCompressFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.string.AbstractFunctionStringTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestUnCompressFunction extends AbstractFunctionStringTestBase {
+public class TestUnCompressFunction extends AbstractFunctionCompressionTestBase {
 
     @Test
     public void testUnCompressFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/condition/AbstractFunctionFlowControlTestBase.java → inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/condition/AbstractFunctionConditionTestBase.java

@@ -24,7 +24,7 @@
 import java.util.ArrayList;
 import java.util.List;
 
-public abstract class AbstractFunctionFlowControlTestBase {
+public abstract class AbstractFunctionConditionTestBase {
 
     protected static final List<FieldInfo> srcFields = new ArrayList<>();
     protected static final List<FieldInfo> dstFields = new ArrayList<>();

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/condition/TestIfFunction.java

@@ -34,7 +34,7 @@
 import java.util.ArrayList;
 import java.util.List;
 
-public class TestIfFunction extends AbstractFunctionFlowControlTestBase {
+public class TestIfFunction extends AbstractFunctionConditionTestBase {
 
     private static final List<FieldInfo> srcFields = new ArrayList<>();
     private static final List<FieldInfo> dstFields = new ArrayList<>();

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/condition/TestIfNullFunction.java

@@ -28,7 +28,7 @@
 import java.util.HashMap;
 import java.util.List;
 
-public class TestIfNullFunction extends AbstractFunctionFlowControlTestBase {
+public class TestIfNullFunction extends AbstractFunctionConditionTestBase {
 
     @Test
     public void testIfNullFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/condition/TestIsNullFunction.java

@@ -21,15 +21,14 @@
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;
 import org.apache.inlong.sdk.transform.pojo.TransformConfig;
 import org.apache.inlong.sdk.transform.process.TransformProcessor;
-import org.apache.inlong.sdk.transform.process.function.arithmetic.AbstractFunctionArithmeticTestBase;
 
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.HashMap;
 import java.util.List;
 
-public class TestIsNullFunction extends AbstractFunctionArithmeticTestBase {
+public class TestIsNullFunction extends AbstractFunctionConditionTestBase {
 
     @Test
     public void testIsNullFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/condition/TestNullIfFunction.java

@@ -28,7 +28,7 @@
 import java.util.HashMap;
 import java.util.List;
 
-public class TestNullIfFunction extends AbstractFunctionFlowControlTestBase {
+public class TestNullIfFunction extends AbstractFunctionConditionTestBase {
 
     @Test
     public void testNullIfFunction() throws Exception {

inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/encryption/AbstractFunctionEncryptionTestBase.java

@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.inlong.sdk.transform.process.function.encryption;
+
+import org.apache.inlong.sdk.transform.pojo.CsvSourceInfo;
+import org.apache.inlong.sdk.transform.pojo.FieldInfo;
+import org.apache.inlong.sdk.transform.pojo.KvSinkInfo;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * AbstractFunctionStringTestBase
+ * description: define static parameters for StringFunction tests
+ */
+public abstract class AbstractFunctionEncryptionTestBase {
+
+    protected static final List<FieldInfo> srcFields = new ArrayList<>();
+    protected static final List<FieldInfo> dstFields = new ArrayList<>();
+    protected static final CsvSourceInfo csvSource;
+    protected static final KvSinkInfo kvSink;
+
+    static {
+        for (int i = 1; i < 4; i++) {
+            FieldInfo field = new FieldInfo();
+            field.setName("string" + i);
+            srcFields.add(field);
+        }
+        for (int i = 1; i < 4; i++) {
+            FieldInfo field = new FieldInfo();
+            field.setName("numeric" + i);
+            srcFields.add(field);
+        }
+        FieldInfo field = new FieldInfo();
+        field.setName("result");
+        dstFields.add(field);
+        csvSource = new CsvSourceInfo("UTF-8", '|', '\\', srcFields);
+        kvSink = new KvSinkInfo("UTF-8", dstFields);
+    }
+}