feat: sort merged functions

apache · Oct 10, 2024 · a3c9a64 · a3c9a64
1 parent 1c3b219
commit a3c9a64
Show file tree

Hide file tree

Showing 40 changed files with 47 additions and 42 deletions.
diff --git a/...unction/flowcontrol/CoalesceFunction.java → .../function/condition/CoalesceFunction.java b/...unction/flowcontrol/CoalesceFunction.java → .../function/condition/CoalesceFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/...cess/function/flowcontrol/IfFunction.java → ...rocess/function/condition/IfFunction.java b/...cess/function/flowcontrol/IfFunction.java → ...rocess/function/condition/IfFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/.../function/flowcontrol/IfNullFunction.java → ...ss/function/condition/IfNullFunction.java b/.../function/flowcontrol/IfNullFunction.java → ...ss/function/condition/IfNullFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/.../function/flowcontrol/IsNullFunction.java → ...ss/function/condition/IsNullFunction.java b/.../function/flowcontrol/IsNullFunction.java → ...ss/function/condition/IsNullFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/.../function/flowcontrol/NullIfFunction.java → ...ss/function/condition/NullIfFunction.java b/.../function/flowcontrol/NullIfFunction.java → ...ss/function/condition/NullIfFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/...ocess/function/string/DecodeFunction.java → ...s/function/encryption/DecodeFunction.java b/...ocess/function/string/DecodeFunction.java → ...s/function/encryption/DecodeFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.string;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/...ocess/function/string/EncodeFunction.java → ...s/function/encryption/EncodeFunction.java b/...ocess/function/string/EncodeFunction.java → ...s/function/encryption/EncodeFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.string;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/...s/function/string/FromBase64Function.java → ...nction/encryption/FromBase64Function.java b/...s/function/string/FromBase64Function.java → ...nction/encryption/FromBase64Function.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.string;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/...cess/function/arithmetic/Md5Function.java → ...cess/function/encryption/Md5Function.java b/...cess/function/arithmetic/Md5Function.java → ...cess/function/encryption/Md5Function.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.arithmetic;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/...cess/function/encrption/Sha2Function.java → ...ess/function/encryption/Sha2Function.java b/...cess/function/encrption/Sha2Function.java → ...ess/function/encryption/Sha2Function.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.encrption;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/...ocess/function/encrption/ShaFunction.java → ...cess/function/encryption/ShaFunction.java b/...ocess/function/encrption/ShaFunction.java → ...cess/function/encryption/ShaFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.encrption;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/...ess/function/string/ToBase64Function.java → ...function/encryption/ToBase64Function.java b/...ess/function/string/ToBase64Function.java → ...function/encryption/ToBase64Function.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.string;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;

diff --git a/...t/java/org/apache/inlong/sdk/transform/process/function/collection/TestArrayFunction.java b/...t/java/org/apache/inlong/sdk/transform/process/function/collection/TestArrayFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/...a/org/apache/inlong/sdk/transform/process/function/collection/TestMapEntriesFunction.java b/...a/org/apache/inlong/sdk/transform/process/function/collection/TestMapEntriesFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/...rg/apache/inlong/sdk/transform/process/function/collection/TestMapFromArraysFunction.java b/...rg/apache/inlong/sdk/transform/process/function/collection/TestMapFromArraysFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/...est/java/org/apache/inlong/sdk/transform/process/function/collection/TestMapFunction.java b/...est/java/org/apache/inlong/sdk/transform/process/function/collection/TestMapFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/...java/org/apache/inlong/sdk/transform/process/function/collection/TestMapKeysFunction.java b/...java/org/apache/inlong/sdk/transform/process/function/collection/TestMapKeysFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/...ava/org/apache/inlong/sdk/transform/process/function/collection/TestMapUnionFunction.java b/...ava/org/apache/inlong/sdk/transform/process/function/collection/TestMapUnionFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/...va/org/apache/inlong/sdk/transform/process/function/collection/TestMapValuesFunction.java b/...va/org/apache/inlong/sdk/transform/process/function/collection/TestMapValuesFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/...va/org/apache/inlong/sdk/transform/process/function/compression/TestCompressFunction.java b/...va/org/apache/inlong/sdk/transform/process/function/compression/TestCompressFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/.../org/apache/inlong/sdk/transform/process/function/compression/TestUnCompressFunction.java b/.../org/apache/inlong/sdk/transform/process/function/compression/TestUnCompressFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/.../AbstractFunctionFlowControlTestBase.java → .../AbstractFunctionFlowControlTestBase.java b/.../AbstractFunctionFlowControlTestBase.java → .../AbstractFunctionFlowControlTestBase.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.pojo.CsvSourceInfo;
 import org.apache.inlong.sdk.transform.pojo.FieldInfo;

diff --git a/.../function/flowcontrol/TestIfFunction.java → ...ss/function/condition/TestIfFunction.java b/.../function/flowcontrol/TestIfFunction.java → ...ss/function/condition/TestIfFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;

diff --git a/...ction/flowcontrol/TestIfNullFunction.java → ...unction/condition/TestIfNullFunction.java b/...ction/flowcontrol/TestIfNullFunction.java → ...unction/condition/TestIfNullFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;

diff --git a/...ction/flowcontrol/TestIsNullFunction.java → ...unction/condition/TestIsNullFunction.java b/...ction/flowcontrol/TestIsNullFunction.java → ...unction/condition/TestIsNullFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;

diff --git a/...ction/flowcontrol/TestNullIfFunction.java → ...unction/condition/TestNullIfFunction.java b/...ction/flowcontrol/TestNullIfFunction.java → ...unction/condition/TestNullIfFunction.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.flowcontrol;
+package org.apache.inlong.sdk.transform.process.function.condition;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 import org.apache.inlong.sdk.transform.encode.SinkEncoderFactory;

diff --git a/...s/function/string/TestDecodeFunction.java → ...nction/encryption/TestDecodeFunction.java b/...s/function/string/TestDecodeFunction.java → ...nction/encryption/TestDecodeFunction.java
@@ -15,12 +15,13 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.string;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 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;

diff --git a/...s/function/string/TestEncodeFunction.java → ...nction/encryption/TestEncodeFunction.java b/...s/function/string/TestEncodeFunction.java → ...nction/encryption/TestEncodeFunction.java
@@ -15,12 +15,13 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.string;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 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;

diff --git a/...nction/string/TestFromBase64Function.java → ...on/encryption/TestFromBase64Function.java b/...nction/string/TestFromBase64Function.java → ...on/encryption/TestFromBase64Function.java
@@ -15,12 +15,13 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.string;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 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;

diff --git a/.../function/arithmetic/TestMd5Function.java → .../function/encryption/TestMd5Function.java b/.../function/arithmetic/TestMd5Function.java → .../function/encryption/TestMd5Function.java
@@ -15,12 +15,13 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.arithmetic;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 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;

diff --git a/.../function/encrption/TestSha2Function.java → ...function/encryption/TestSha2Function.java b/.../function/encrption/TestSha2Function.java → ...function/encryption/TestSha2Function.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.encrption;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 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;
 

diff --git a/...s/function/encrption/TestShaFunction.java → .../function/encryption/TestShaFunction.java b/...s/function/encrption/TestShaFunction.java → .../function/encryption/TestShaFunction.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.encrption;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 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;
 

diff --git a/...function/string/TestToBase64Function.java → ...tion/encryption/TestToBase64Function.java b/...function/string/TestToBase64Function.java → ...tion/encryption/TestToBase64Function.java
@@ -15,12 +15,13 @@
  * limitations under the License.
  */
 
-package org.apache.inlong.sdk.transform.process.function.string;
+package org.apache.inlong.sdk.transform.process.function.encryption;
 
 import org.apache.inlong.sdk.transform.decode.SourceDecoderFactory;
 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;

diff --git a/...va/org/apache/inlong/sdk/transform/process/function/json/TestJsonArrayAppendFunction.java b/...va/org/apache/inlong/sdk/transform/process/function/json/TestJsonArrayAppendFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/...st/java/org/apache/inlong/sdk/transform/process/function/json/TestJsonArraysFunction.java b/...st/java/org/apache/inlong/sdk/transform/process/function/json/TestJsonArraysFunction.java
@@ -24,8 +24,8 @@
 import org.apache.inlong.sdk.transform.pojo.KvSinkInfo;
 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;
 

diff --git a/...st/java/org/apache/inlong/sdk/transform/process/function/json/TestJsonExistsFunction.java b/...st/java/org/apache/inlong/sdk/transform/process/function/json/TestJsonExistsFunction.java
@@ -21,8 +21,8 @@
 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;
 

diff --git a/...est/java/org/apache/inlong/sdk/transform/process/function/json/TestJsonQueryFunction.java b/...est/java/org/apache/inlong/sdk/transform/process/function/json/TestJsonQueryFunction.java
@@ -21,8 +21,8 @@
 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;