org.gcube.dataanalysis.ecoengine.interfaces

Class DataAnalysis

java.lang.Object

org.gcube.dataanalysis.ecoengine.interfaces.DataAnalysis

All Implemented Interfaces:

ComputationalAgent, Evaluator

Direct Known Subclasses:

DiscrepancyAnalysis, DistributionQualityAnalysis, HabitatRepresentativeness

public abstract class DataAnalysis
extends Object
implements Evaluator

Implements a mono-thread data analysis process Status is managed outside the class and analysis is simply conducted by initializing and applying procedure

Author:

coro

Field Summary

Fields

Modifier and Type	Field and Description
protected AlgorithmConfiguration	config
protected org.hibernate.SessionFactory	connection
protected int	processedRecords
protected ResourceFactory	resourceManager
protected float	status

Constructor Summary

Constructors

Constructor and Description
DataAnalysis()

Method Summary

Methods

Modifier and Type	Method and Description
abstract LinkedHashMap<String,String>	analyze()
void	compute()
INFRASTRUCTURE	getInfrastructure() The weight of this procedure is the lowest as it runs on local machine
StatisticalType	getOutput()
String	getResourceLoad() calculates the number of processed records per unity of time: the timing is calculated internally by the resourceManager and used when the method is interrogated
String	getResources() gets the occupancy of the resource: in this case one thread
float	getStatus() gets the internal status of the operation
void	init()
void	init(boolean initRapidMiner)
void	setConfiguration(AlgorithmConfiguration config)
void	shutdown()
static void	visualizeResults(HashMap<String,Object> results) visualizes the results of the analysis

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gcube.dataanalysis.ecoengine.interfaces.ComputationalAgent

getDescription, getInputParameters

Field Detail

resourceManager

protected ResourceFactory resourceManager

processedRecords

protected int processedRecords

status

protected float status

config

protected AlgorithmConfiguration config

connection

protected org.hibernate.SessionFactory connection

Constructor Detail

DataAnalysis

public DataAnalysis()

Method Detail

analyze

public abstract LinkedHashMap<String,String> analyze()
                                              throws Exception

Throws:

Exception

compute

public void compute()
             throws Exception

Specified by:

compute in interface ComputationalAgent

Throws:

Exception

getOutput

public StatisticalType getOutput()

Specified by:

getOutput in interface ComputationalAgent

getResourceLoad

public String getResourceLoad()

calculates the number of processed records per unity of time: the timing is calculated internally by the resourceManager and used when the method is interrogated

Specified by:

getResourceLoad in interface ComputationalAgent

getResources

public String getResources()

gets the occupancy of the resource: in this case one thread

Specified by:

getResources in interface ComputationalAgent

getInfrastructure

public INFRASTRUCTURE getInfrastructure()

The weight of this procedure is the lowest as it runs on local machine

Specified by:

getInfrastructure in interface ComputationalAgent

getStatus

public float getStatus()

gets the internal status of the operation

Specified by:

getStatus in interface ComputationalAgent

visualizeResults

public static void visualizeResults(HashMap<String,Object> results)

visualizes the results of the analysis

Parameters:

results -

init

public void init()
          throws Exception

Specified by:

init in interface ComputationalAgent

Throws:

Exception

init

public void init(boolean initRapidMiner)
          throws Exception

Throws:

Exception

setConfiguration

public void setConfiguration(AlgorithmConfiguration config)

Specified by:

setConfiguration in interface ComputationalAgent

shutdown

public void shutdown()

Specified by:

shutdown in interface ComputationalAgent