소스 검색

feat: add udf

JimZhang 2 년 전
부모
커밋
d87d02bc49
1개의 변경된 파일30개의 추가작업 그리고 0개의 파일을 삭제
  1. 30 0
      src/main/java/com/winhc/bigdata/udf/StringAnyContains.java

+ 30 - 0
src/main/java/com/winhc/bigdata/udf/StringAnyContains.java

@@ -0,0 +1,30 @@
+package com.winhc.bigdata.udf;
+
+
+import com.aliyun.odps.udf.UDF;
+import org.apache.commons.lang.StringUtils;
+
+/**
+ * @author ZhangJi
+ * @since 2022-04-13 18:39
+ */
+public class StringAnyContains extends UDF {
+    public Boolean evaluate(String val,String... args) {
+        if(StringUtils.isEmpty(val))return false;
+        if(args==null||args.length==0) {
+            return false;
+        }
+        for(String arg:args) {
+            if(arg!=null&&val.contains(arg)) {
+                return true;
+            }
+        }
+        return false;
+    }
+
+    public static void main(String[] args) {
+        StringAnyContains udf=new StringAnyContains();
+
+
+    }
+}