init

.gitignore

@@ -0,0 +1,21 @@
+*~
+*.#*
+*#*#
+*.swp
+*.ipr
+*.iml
+*.iws
+*.pyc
+*.pyo
+.idea/
+.idea_modules/
+.settings
+.cache
+target/
+.project
+.classpath
+.DS_Store
+metastore_db/
+derby.log
+log4j.properties
+dependency-reduced-pom.xml

pom.xml

@@ -0,0 +1,61 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.winhc</groupId>
+    <artifactId>UDF_Max</artifactId>
+    <version>0.0.1</version>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <sdk.version>0.33.7-public</sdk.version>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.aliyun.odps</groupId>
+            <artifactId>odps-sdk-core</artifactId>
+            <version>${sdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun.odps</groupId>
+            <artifactId>odps-sdk-udf</artifactId>
+            <version>${sdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun.odps</groupId>
+            <artifactId>odps-udf-local</artifactId>
+            <version>${sdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun.odps</groupId>
+            <artifactId>odps-sdk-mapred</artifactId>
+            <version>${sdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun.odps</groupId>
+            <artifactId>odps-mapred-local</artifactId>
+            <version>${sdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun.odps</groupId>
+            <artifactId>odps-sdk-graph</artifactId>
+            <version>${sdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun.odps</groupId>
+            <artifactId>odps-graph-local</artifactId>
+            <version>${sdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.12</version>
+        </dependency>
+    </dependencies>
+
+</project>

src/main/java/com/winhc/bigdata/udf/JudriskCourtAnnouncementEqu.java

@@ -0,0 +1,32 @@
+package com.winhc.bigdata.udf;
+
+import com.aliyun.odps.udf.UDF;
+import com.aliyun.odps.utils.StringUtils;
+
+/**
+ * @Author: XuJiakai
+ * @Date: 2020/5/15 16:43
+ * @Description: 法院公告 原告被告判断
+ */
+public class JudriskCourtAnnouncementEqu extends UDF {
+    /**
+     * 功能描述:法院公告案件生份判断
+     *
+     * @param companyName 公司名
+     * @param personName  人名
+     * @param accuser     公诉人/原告/上诉人/申请人
+     * @param party       被告人/被告/被上诉人/被申请人
+     * @return: java.lang.Integer   0->未知，1->公诉人/原告/上诉人/申请人，2->被告人/被告/被上诉人/被申请人
+     * @auther: xjk
+     * @date: 2020/5/15 16:46
+     */
+    public Integer evaluate(String companyName, String personName, String accuser, String party) {
+        if (StringUtils.isNotBlank(companyName)) {
+            return companyName.equals(accuser) ? 1 : companyName.equals(party) ? 2 : 0;
+        }
+        if (StringUtils.isNotBlank(personName)) {
+            return personName.equals(accuser) ? 1 : personName.equals(party) ? 2 : 0;
+        }
+        return 0;
+    }
+}

src/main/java/com/winhc/bigdata/udf/StringCleanup.java

@@ -0,0 +1,19 @@
+package com.winhc.bigdata.udf;
+
+import com.aliyun.odps.udf.UDF;
+import com.aliyun.odps.utils.StringUtils;
+
+import java.util.regex.Pattern;
+
+/**
+ * @Author: XuJiakai
+ * @Date: 2020/5/14 16:26
+ * @Description: 字符串去符号
+ */
+public class StringCleanup extends UDF {
+    private static final Pattern pattern = Pattern.compile("[^\\u4e00-\\u9fa50-9a-zA-Z]");
+
+    public String evaluate(String val) {
+        return StringUtils.isNotBlank(val) ? pattern.matcher(val).replaceAll("") : "";
+    }
+}