gCubeSystem
/
ecological-engine
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngine@122895 82a268e6-3cf1-43bd-a215-b396298e98cf

This commit is contained in:
Gianpaolo Coro 2016-02-08 10:23:36 +00:00
parent aff9cbab84
commit 6f770e9014
4 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/gcube/dataanalysis/ecoengine/configuration/AlgorithmConfiguration.java
View File

@ -67,6 +67,7 @@ public class AlgorithmConfiguration extends LexicalEngineConfiguration implement
private String configPath; private String configPath;
private String persistencePath; private String persistencePath;
private String tableSpace; private String tableSpace;
private String taskID="";
private List<String> endpoints; private List<String> endpoints;
@ -204,6 +205,12 @@ public class AlgorithmConfiguration extends LexicalEngineConfiguration implement
this.tableSpace = tableSpace; this.tableSpace = tableSpace;
} }
public void setTaskID(String taskID) {
this.taskID = taskID;
}
public String getTaskID() {
return taskID;
}
} }

1
src/main/java/org/gcube/dataanalysis/ecoengine/interfaces/ComputationalAgent.java
View File

@ -33,4 +33,5 @@ public interface ComputationalAgent {
public void compute() throws Exception; public void compute() throws Exception;
} }

2
src/main/java/org/gcube/dataanalysis/ecoengine/utils/LMEEnum.java
View File

@ -19,7 +19,7 @@ public class LMEEnum extends DynamicEnum {
en.addEnum(LMEEnumType.class, "CIAO"); en.addEnum(LMEEnumType.class, "CIAO");
en.addEnum(LMEEnumType.class, "TEST"); en.addEnum(LMEEnumType.class, "TEST");
en.addEnum(LMEEnumType.class, "MIAO*_$"); en.addEnum(LMEEnumType.class, "MIAO *_$");
System.out.println(Arrays.deepToString(LMEEnumType.values())); System.out.println(Arrays.deepToString(LMEEnumType.values()));
/* /*

13
src/main/java/org/gcube/dataanalysis/ecoengine/utils/ZipTools.java
View File

@ -1,9 +1,12 @@
package org.gcube.dataanalysis.ecoengine.utils; package org.gcube.dataanalysis.ecoengine.utils;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File; import java.io.File;
import java.io.FileInputStream; import java.io.FileInputStream;
import java.io.FileOutputStream; import java.io.FileOutputStream;
import java.io.IOException; import java.io.IOException;
import java.util.Date;
import java.util.zip.ZipEntry; import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream; import java.util.zip.ZipInputStream;
import java.util.zip.ZipOutputStream; import java.util.zip.ZipOutputStream;
@ -12,7 +15,7 @@ import org.gcube.contentmanagement.lexicalmatcher.utils.AnalysisLogger;
public class ZipTools { public class ZipTools {
public static void unZip(String zipFile, String outputFolder) throws Exception { public static void unZip(String zipFile, String outputFolder) throws Exception {
byte[] buffer = new byte[1024]; byte[] buffer = new byte[1024];
@ -36,10 +39,11 @@ public class ZipTools {
AnalysisLogger.getLogger().debug("Unzipping : " + newFile.getAbsoluteFile()); AnalysisLogger.getLogger().debug("Unzipping : " + newFile.getAbsoluteFile());
// create all non exists folders if (ze.isDirectory())
// else you will hit FileNotFoundException for compressed folder new File(outputFolder,ze.getName()).mkdir();
else{
new File(newFile.getParent()).mkdirs(); new File(newFile.getParent()).mkdirs();
FileOutputStream fos = new FileOutputStream(newFile); FileOutputStream fos = new FileOutputStream(newFile);
int len; int len;
@ -48,6 +52,7 @@ public class ZipTools {
} }
fos.close(); fos.close();
}
ze = zis.getNextEntry(); ze = zis.getNextEntry();
} }