UDF2<String, String, Boolean> contains = new UDF2<String, String, Boolean>() {
private static final long serialVersionUID = -5239951370238629896L;
@Override
public Boolean call(String t1, String t2) throws Exception {
Pattern p1 = Pattern.compile(t1);
Pattern p2 = Pattern.compile(t2);
return p1.toString().contains(p2.toString());
}
};
spark.udf().register("contains", contains, DataTypes.BooleanType);
UDF2<String, String, Boolean> contains = new UD