From 063842ad48f99408a07a16788a199659a7629f43 Mon Sep 17 00:00:00 2001 From: Francesco Mangiacrapa Date: Thu, 26 Apr 2018 10:38:33 +0000 Subject: [PATCH] Working on [Project Activity #11690] Execute Data Miner processes from Workspace git-svn-id: http://svn.research-infrastructures.eu/public/d4science/gcube/trunk/Common/workspace-task-executor-library@167239 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../ConfigurableTask.java | 10 +- .../WorkspaceDataMinerTaskExecute.java | 98 +++++++++++++++++++ .../AlgorithmConfiguration.java | 2 +- 3 files changed, 104 insertions(+), 6 deletions(-) create mode 100644 src/main/java/org/gcube/common/workspacetaskexecutor/dataminer/WorkspaceDataMinerTaskExecute.java rename src/main/java/org/gcube/common/workspacetaskexecutor/shared/{homelibrary => dataminer}/AlgorithmConfiguration.java (97%) diff --git a/src/main/java/org/gcube/common/workspacetaskexecutor/ConfigurableTask.java b/src/main/java/org/gcube/common/workspacetaskexecutor/ConfigurableTask.java index 75623bf..729e2a1 100644 --- a/src/main/java/org/gcube/common/workspacetaskexecutor/ConfigurableTask.java +++ b/src/main/java/org/gcube/common/workspacetaskexecutor/ConfigurableTask.java @@ -11,20 +11,20 @@ import org.gcube.common.workspacetaskexecutor.shared.ItemNotExecutable; * * @author Francesco Mangiacrapa francesco.mangiacrapa@isti.cnr.it * Apr 26, 2018 + * @param the generic type */ -public interface ConfigurableTask { - +public interface ConfigurableTask { /** * Removes the task config. * - * @param config the config + * @param workspaceItemId the workspace item id * @return the boolean * @throws ItemNotExecutable the item not executable * @throws Exception the exception */ - Boolean removeTaskConfig(TaskConfiguration config) throws ItemNotExecutable, Exception; + Boolean removeTaskConfig(String workspaceItemId) throws ItemNotExecutable, Exception; /** @@ -35,5 +35,5 @@ public interface ConfigurableTask { * @throws ItemNotExecutable the item not executable * @throws Exception the exception */ - Boolean addTaskConfig(TaskConfiguration config) throws ItemNotExecutable, Exception; + Boolean addTaskConfig(I config) throws ItemNotExecutable, Exception; } diff --git a/src/main/java/org/gcube/common/workspacetaskexecutor/dataminer/WorkspaceDataMinerTaskExecute.java b/src/main/java/org/gcube/common/workspacetaskexecutor/dataminer/WorkspaceDataMinerTaskExecute.java new file mode 100644 index 0000000..72e97e5 --- /dev/null +++ b/src/main/java/org/gcube/common/workspacetaskexecutor/dataminer/WorkspaceDataMinerTaskExecute.java @@ -0,0 +1,98 @@ +package org.gcube.common.workspacetaskexecutor.dataminer; + +import org.gcube.common.workspacetaskexecutor.CheckableTask; +import org.gcube.common.workspacetaskexecutor.ConfigurableTask; +import org.gcube.common.workspacetaskexecutor.ExecutableTask; +import org.gcube.common.workspacetaskexecutor.shared.ItemNotExecutable; +import org.gcube.common.workspacetaskexecutor.shared.dataminer.AlgorithmConfiguration; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + + +// TODO: Auto-generated Javadoc +/** + * The Class WorkspaceThreddsSynchronize. + * + * @author Francesco Mangiacrapa francesco.mangiacrapa@isti.cnr.it + * Feb 14, 2018 + */ +public class WorkspaceDataMinerTaskExecute implements ExecutableTask, ConfigurableTask, CheckableTask{ + + /** The logger. */ + private static Logger logger = LoggerFactory.getLogger(WorkspaceDataMinerTaskExecute.class); + + /* (non-Javadoc) + * @see org.gcube.common.workspacetaskexecutor.CheckableTask#checkItemExecutable(java.lang.String) + */ + @Override + public AlgorithmConfiguration checkItemExecutable(String itemId) throws ItemNotExecutable, Exception { + + // TODO Auto-generated method stub + return null; + } + + /* (non-Javadoc) + * @see org.gcube.common.workspacetaskexecutor.ConfigurableTask#removeTaskConfig(java.lang.Object) + */ + @Override + public Boolean removeTaskConfig(String workspaceItemId) throws ItemNotExecutable, Exception { + + // TODO Auto-generated method stub + return null; + } + + /* (non-Javadoc) + * @see org.gcube.common.workspacetaskexecutor.ConfigurableTask#addTaskConfig(java.lang.Object) + */ + @Override + public Boolean addTaskConfig(AlgorithmConfiguration config) throws ItemNotExecutable, Exception { + + // TODO Auto-generated method stub + return null; + } + + /* (non-Javadoc) + * @see org.gcube.common.workspacetaskexecutor.ExecutableTask#doRun(java.lang.String) + */ + @Override + public AlgorithmConfiguration doRun(String itemId) + throws ItemNotExecutable, Exception { + + // TODO Auto-generated method stub + return null; + } + + /* (non-Javadoc) + * @see org.gcube.common.workspacetaskexecutor.ExecutableTask#stopRun(java.lang.String) + */ + @Override + public Boolean stopRun(String itemId) + throws ItemNotExecutable, Exception { + + // TODO Auto-generated method stub + return null; + } + + /* (non-Javadoc) + * @see org.gcube.common.workspacetaskexecutor.ExecutableTask#monitorRunStatus(java.lang.String) + */ + @Override + public AlgorithmConfiguration monitorRunStatus(String itemId) + throws ItemNotExecutable, Exception { + + // TODO Auto-generated method stub + return null; + } + + /* (non-Javadoc) + * @see org.gcube.common.workspacetaskexecutor.ExecutableTask#registerCallbackForId(java.lang.String) + */ + @Override + public void registerCallbackForId(String itemId) + throws Exception { + + // TODO Auto-generated method stub + + } + +} diff --git a/src/main/java/org/gcube/common/workspacetaskexecutor/shared/homelibrary/AlgorithmConfiguration.java b/src/main/java/org/gcube/common/workspacetaskexecutor/shared/dataminer/AlgorithmConfiguration.java similarity index 97% rename from src/main/java/org/gcube/common/workspacetaskexecutor/shared/homelibrary/AlgorithmConfiguration.java rename to src/main/java/org/gcube/common/workspacetaskexecutor/shared/dataminer/AlgorithmConfiguration.java index 1365031..4018a87 100644 --- a/src/main/java/org/gcube/common/workspacetaskexecutor/shared/homelibrary/AlgorithmConfiguration.java +++ b/src/main/java/org/gcube/common/workspacetaskexecutor/shared/dataminer/AlgorithmConfiguration.java @@ -2,7 +2,7 @@ * */ -package org.gcube.common.workspacetaskexecutor.shared.homelibrary; +package org.gcube.common.workspacetaskexecutor.shared.dataminer; import java.io.Serializable; import java.util.Map;