From 2e8fd2d1ddb6ba4c58d7df8b676105173feed339 Mon Sep 17 00:00:00 2001 From: Gianpaolo Coro Date: Fri, 22 Jun 2012 16:04:46 +0000 Subject: [PATCH] git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngine@55943 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../SpatialProbabilityDistributionNode.java | 25 ++++++++++++------- 1 file changed, 16 insertions(+), 9 deletions(-) diff --git a/src/main/java/org/gcube/dataanalysis/ecoengine/interfaces/SpatialProbabilityDistributionNode.java b/src/main/java/org/gcube/dataanalysis/ecoengine/interfaces/SpatialProbabilityDistributionNode.java index 5667bd3..5a52b0d 100644 --- a/src/main/java/org/gcube/dataanalysis/ecoengine/interfaces/SpatialProbabilityDistributionNode.java +++ b/src/main/java/org/gcube/dataanalysis/ecoengine/interfaces/SpatialProbabilityDistributionNode.java @@ -4,24 +4,31 @@ import org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration; public interface SpatialProbabilityDistributionNode extends SpatialProbabilityDistribution { - //initialization of the distribution model + //initialization of ta single node public void initSingleNode(AlgorithmConfiguration config); - - //preprocessing after the whole calculation - public void postProcess(); //get the internal processing status for the single step calculation public float getInternalStatus(); - public int executeNode(int cellOrdinal, int chunksize, int speciesOrdinal, int speciesChunkSize, String pathToFiles, String logfile); + //execute a single node + public int executeNode(int cellStarIndex, int numberOfCellsToProcess, int speciesStartIndex, int numberOfSpeciesToProcess, String sandboxFolder, String logfileNameToProduce); + // An initialization phase in which the inputs are initialized public void setup(AlgorithmConfiguration config) throws Exception; + //get overall number of species to process public int getNumberOfSpecies(); - + + //get overall number of geographical information to process public int getNumberOfGeoInfo(); - - public int getOverallProcessedInfo(); - + + //get overall number of processed species + public int getNumberOfProcessedSpecies(); + + //stop the sexecution of the node public void stop(); + + //prostprocess after the whole calculation : reduce operation + public void postProcess(); + }