|
|
|
@ -73,13 +73,11 @@ public class UDFUtils {
|
|
|
|
|
String resourceFullName; |
|
|
|
|
Set<Map.Entry<UdfFunc,String>> entries = udfFuncTenantCodeMap.entrySet(); |
|
|
|
|
for (Map.Entry<UdfFunc,String> entry:entries){ |
|
|
|
|
String prefixPath = defaultFS.startsWith("file://") ? "file://" : defaultFS; |
|
|
|
|
String uploadPath = HadoopUtils.getHdfsUdfDir(entry.getValue()); |
|
|
|
|
if (!uploadPath.startsWith("hdfs:")) { |
|
|
|
|
uploadPath = defaultFS + uploadPath; |
|
|
|
|
} |
|
|
|
|
resourceFullName = entry.getKey().getResourceName(); |
|
|
|
|
resourceFullName = resourceFullName.startsWith("/") ? resourceFullName : String.format("/%s",resourceFullName); |
|
|
|
|
sqls.add(String.format("add jar %s%s", uploadPath, resourceFullName)); |
|
|
|
|
sqls.add(String.format("add jar %s%s%s", prefixPath, uploadPath, resourceFullName)); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|