org.gcube.dataanalysis.executor.nodes.transducers.bionym
Class BionymFlexibleWorkflowTransducer

java.lang.Object
  org.gcube.dataanalysis.ecoengine.interfaces.ActorNode
      org.gcube.dataanalysis.executor.nodes.transducers.bionym.BionymFlexibleWorkflowTransducer

All Implemented Interfaces:

org.gcube.dataanalysis.ecoengine.interfaces.GenericAlgorithm

Direct Known Subclasses:

BionymBiodiv

public class BionymFlexibleWorkflowTransducer
extends org.gcube.dataanalysis.ecoengine.interfaces.ActorNode

Field Summary

protected org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration	currentconfig
protected org.hibernate.SessionFactory	dbconnection
static String	destinationTableLableParam
static String	destinationTableParam
static String	matcherParamPrefix
static int	maxMatchersInterface
static int	maxMatchersReal
static String	maxresultsParamPrefix
static String	originTableParam
int	prevbroadcastTimePeriod
int	prevmaxMessages
int	prevmaxNumberOfStages
static String	rawnamesColumnParam
static String	thresholdParamPrefix

Constructor Summary

BionymFlexibleWorkflowTransducer()

Method Summary

List<Matcher>	buildMatcherList(org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration config, String sandboxFolder, HashMap<String,String> globalparameters)
int	executeNode(int leftStartIndex, int numberOfLeftElementsToProcess, int rightStartIndex, int numberOfRightElementsToProcess, boolean duplicate, String sandboxFolder, String nodeConfigurationFileObject, String logfileNameToProduce)
String	getDescription()
static Matcher	getEnum2Matcher(YasmeenGlobalParameters.BuiltinMatchers matcher, String sandboxFolder, double threshold, int maxResults, HashMap<String,String> parameters)
List<org.gcube.dataanalysis.ecoengine.datatypes.StatisticalType>	getInputParameters()
float	getInternalStatus()
String	getName()
int	getNumberOfLeftElements()
int	getNumberOfRightElements()
org.gcube.dataanalysis.ecoengine.datatypes.StatisticalType	getOutput()
org.gcube.dataanalysis.ecoengine.configuration.ALG_PROPS[]	getProperties()
void	initSingleNode(org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration config)
void	postProcess(boolean manageDuplicates, boolean manageFault)
void	setup(org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration config)
void	stop()

Methods inherited from class org.gcube.dataanalysis.ecoengine.interfaces.ActorNode

main

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

currentconfig

protected org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration currentconfig

dbconnection

protected org.hibernate.SessionFactory dbconnection

prevbroadcastTimePeriod

public int prevbroadcastTimePeriod

prevmaxNumberOfStages

public int prevmaxNumberOfStages

prevmaxMessages

public int prevmaxMessages

destinationTableParam

public static String destinationTableParam

destinationTableLableParam

public static String destinationTableLableParam

originTableParam

public static String originTableParam

rawnamesColumnParam

public static String rawnamesColumnParam

matcherParamPrefix

public static String matcherParamPrefix

thresholdParamPrefix

public static String thresholdParamPrefix

maxresultsParamPrefix

public static String maxresultsParamPrefix

maxMatchersInterface

public static int maxMatchersInterface

maxMatchersReal

public static int maxMatchersReal

Constructor Detail

BionymFlexibleWorkflowTransducer

public BionymFlexibleWorkflowTransducer()

Method Detail

getEnum2Matcher

public static Matcher getEnum2Matcher(YasmeenGlobalParameters.BuiltinMatchers matcher,
                                      String sandboxFolder,
                                      double threshold,
                                      int maxResults,
                                      HashMap<String,String> parameters)

buildMatcherList

public List<Matcher> buildMatcherList(org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration config,
                                      String sandboxFolder,
                                      HashMap<String,String> globalparameters)

getProperties

public org.gcube.dataanalysis.ecoengine.configuration.ALG_PROPS[] getProperties()

getName

public String getName()

getDescription

public String getDescription()

getInputParameters

public List<org.gcube.dataanalysis.ecoengine.datatypes.StatisticalType> getInputParameters()

getOutput

public org.gcube.dataanalysis.ecoengine.datatypes.StatisticalType getOutput()

initSingleNode

public void initSingleNode(org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration config)

Specified by:

initSingleNode in class org.gcube.dataanalysis.ecoengine.interfaces.ActorNode

getInternalStatus

public float getInternalStatus()

Specified by:

getInternalStatus in class org.gcube.dataanalysis.ecoengine.interfaces.ActorNode

executeNode

public int executeNode(int leftStartIndex,
                       int numberOfLeftElementsToProcess,
                       int rightStartIndex,
                       int numberOfRightElementsToProcess,
                       boolean duplicate,
                       String sandboxFolder,
                       String nodeConfigurationFileObject,
                       String logfileNameToProduce)

Specified by:

executeNode in class org.gcube.dataanalysis.ecoengine.interfaces.ActorNode

setup

public void setup(org.gcube.dataanalysis.ecoengine.configuration.AlgorithmConfiguration config)
           throws Exception

Specified by:

setup in class org.gcube.dataanalysis.ecoengine.interfaces.ActorNode

Throws:

Exception

getNumberOfRightElements

public int getNumberOfRightElements()

Specified by:

getNumberOfRightElements in class org.gcube.dataanalysis.ecoengine.interfaces.ActorNode

getNumberOfLeftElements

public int getNumberOfLeftElements()

Specified by:

getNumberOfLeftElements in class org.gcube.dataanalysis.ecoengine.interfaces.ActorNode

stop

public void stop()

Specified by:

stop in class org.gcube.dataanalysis.ecoengine.interfaces.ActorNode

postProcess

public void postProcess(boolean manageDuplicates,
                        boolean manageFault)

Specified by:

postProcess in class org.gcube.dataanalysis.ecoengine.interfaces.ActorNode