|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectstartup.cluster.ClusterClassificationAction
public class ClusterClassificationAction
This class is a special wrapup around a normal classificationaction. It is designed to execute a normal classificationAction on a GridEngine cluster node, while the parent FunSiPWorkflow object is residing on the master node. The upside of this implementation is the fact that this way the cluster can be utilized, without having to resort to techniques such as java RMI. The downside however is the fact that we have to read and write console-commands to standard output in order to check whether or not the classificationActions running on the cluster nodes have finished or not. This class should in this stage only be used for speeding up the optimalization procedure, which is necessary before building a classification model or using said classification model to evaluate sequence files.
Field Summary | |
---|---|
static long |
SLEEP_TIME
The time a node waits between anouncing its finish (milliseconds). |
Constructor Summary | |
---|---|
ClusterClassificationAction(ClassificationAction ca,
FunSiPWorkflow workflow,
java.lang.String index,
org.apache.log4j.Logger logger)
Constructor. |
Method Summary | |
---|---|
int |
getNumLines(java.io.File f)
This method simply tries to return the number of lines in a file. |
int |
getSubmitNumber(java.io.File outputFile,
java.io.File errorFile)
This method parses the submit-number from the outputfile. |
void |
run()
Implementation of the run()-method of the Runnable interface. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final long SLEEP_TIME
Constructor Detail |
---|
public ClusterClassificationAction(ClassificationAction ca, FunSiPWorkflow workflow, java.lang.String index, org.apache.log4j.Logger logger)
ca
- The classification action which needs to be executed on a cluster node.workflow
- The parent workflow.index
- The index of the classification action in the parent workflow.logger
- The logging facility.Method Detail |
---|
public void run()
run
in interface java.lang.Runnable
public int getNumLines(java.io.File f)
f
- The file f, from which the number of lines should be extracted.
public int getSubmitNumber(java.io.File outputFile, java.io.File errorFile)
outputFile
- The file containing standard output from the qsub-commanderrorFile
- The file containing error output from the qsub-command
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |