yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-08-23 00:28:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add all jython directories found in class path to jython interpreter's path (#751)

Browse Source
This commit is contained in:
Mars Lan 2017-09-15 16:02:20 -07:00 committed by GitHub
parent 3a16b6e280
commit c7d4130fab
1 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
wherehows-etl/src/main/java/metadata/etl/EtlJob.java
View File

@ -14,7 +14,9 @@
package metadata.etl; package metadata.etl;
import java.io.File; import java.io.File;
import java.io.IOException;
import java.net.URL; import java.net.URL;
import java.util.Enumeration;
import java.util.Properties; import java.util.Properties;
import org.python.core.PyDictionary; import org.python.core.PyDictionary;
import org.python.core.PyString; import org.python.core.PyString;
@ -50,7 +52,17 @@ public abstract class EtlJob extends BaseJob {
} }
private void addJythonToPath(PySystemState pySystemState) { private void addJythonToPath(PySystemState pySystemState) {
URL url = classLoader.getResource("jython"); Enumeration<URL> urls;
try {
urls = classLoader.getResources("jython/");
} catch (IOException e) {
logger.info("Failed to get resource: {}", e.getMessage());
return;
}
while (urls.hasMoreElements()) {
URL url = urls.nextElement();
logger.debug("jython url: {}", url.getPath());
if (url != null) { if (url != null) {
File file = new File(url.getFile()); File file = new File(url.getFile());
String path = file.getPath(); String path = file.getPath();
@ -60,6 +72,7 @@ public abstract class EtlJob extends BaseJob {
pySystemState.path.append(new PyString(path.replace("!", ""))); pySystemState.path.append(new PyString(path.replace("!", "")));
} }
} }
}
/** /**
* Copy all properties into jython environment * Copy all properties into jython environment