[INLONG-11028][SDK] Transform SQL support UrlEncode & UrlDecode funct…

…ions Add license
MOONSakura0614 · Sep 6, 2024 · 65a0d6d · 65a0d6d
1 parent 310a9a2
commit 65a0d6d
Show file tree

Hide file tree

Showing 4 changed files with 79 additions and 6 deletions.
diff --git a/...sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/UrlDecodeFunction.java b/...sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/UrlDecodeFunction.java
@@ -1,3 +1,20 @@
+/*
+ * 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;
 
 import org.apache.inlong.sdk.transform.decode.SourceData;

diff --git a/...sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/UrlEncodeFunction.java b/...sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/UrlEncodeFunction.java
@@ -1,14 +1,33 @@
+/*
+ * 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;
-import java.io.UnsupportedEncodingException;
-import java.net.URLEncoder;
-import java.nio.charset.StandardCharsets;
+
 import org.apache.inlong.sdk.transform.decode.SourceData;
 import org.apache.inlong.sdk.transform.process.Context;
 import org.apache.inlong.sdk.transform.process.operator.OperatorTools;
 import org.apache.inlong.sdk.transform.process.parser.ValueParser;
 
 import net.sf.jsqlparser.expression.Function;
 
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
+
 /**
  * UrlEncodeFunction
  * description: Translates a string into ‘application/x-www-form-urlencoded’ format using the UTF-8 encoding scheme.
@@ -50,4 +69,3 @@ public static void main(String[] args) throws UnsupportedEncodingException {
         System.out.println(URLEncoder.encode(s, StandardCharsets.UTF_8.toString()));
     }
 }
-
diff --git a/...t/java/org/apache/inlong/sdk/transform/process/function/string/TestUrlDecodeFunction.java b/...t/java/org/apache/inlong/sdk/transform/process/function/string/TestUrlDecodeFunction.java
@@ -1,9 +1,27 @@
+/*
+ * 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.string;
 
 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.junit.Assert;
 import org.junit.Test;
 
@@ -21,7 +39,8 @@ public void testUrlDecodeFunction() throws Exception {
                         SinkEncoderFactory.createKvEncoder(kvSink));
 
         // case1: url_decode('https%3A%2F%2Fwww.google.com%2Fsearch%3Fq%3Djava+url+encode')
-        List<String> output1 = processor.transform("https%3A%2F%2Fwww.google.com%2Fsearch%3Fq%3Djava+url+encode|banana|cloud|1", new HashMap<>());
+        List<String> output1 = processor.transform(
+                "https%3A%2F%2Fwww.google.com%2Fsearch%3Fq%3Djava+url+encode|banana|cloud|1", new HashMap<>());
         Assert.assertEquals(1, output1.size());
         Assert.assertEquals(output1.get(0), "result=https://www.google.com/search?q=java url encode");
 

diff --git a/...t/java/org/apache/inlong/sdk/transform/process/function/string/TestUrlEncodeFunction.java b/...t/java/org/apache/inlong/sdk/transform/process/function/string/TestUrlEncodeFunction.java
@@ -1,9 +1,27 @@
+/*
+ * 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.string;
 
 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.junit.Assert;
 import org.junit.Test;
 
@@ -21,7 +39,8 @@ public void testUrlEncodeFunction() throws Exception {
                         SinkEncoderFactory.createKvEncoder(kvSink));
 
         // case1: url_encode('https://www.google.com/search?q=java url encode')
-        List<String> output1 = processor.transform("https://www.google.com/search?q=java url encode|banana|cloud|1", new HashMap<>());
+        List<String> output1 =
+                processor.transform("https://www.google.com/search?q=java url encode|banana|cloud|1", new HashMap<>());
         Assert.assertEquals(1, output1.size());
         Assert.assertEquals(output1.get(0), "result=https%3A%2F%2Fwww.google.com%2Fsearch%3Fq%3Djava+url+encode");