compbio.stat.collector

Class ExecutionStatCollector

java.lang.Object

compbio.stat.collector.ExecutionStatCollector

All Implemented Interfaces:

java.lang.Runnable

public class ExecutionStatCollector
extends java.lang.Object
implements java.lang.Runnable

Class assumptions: 1. Number of runs of each WS = number of folders with name 2. Number of successful runs = all runs with no result file 3. Per period of time = limit per file creating time 4. Runtime (avg/max) = finish time - start time 5. Task & result size = result.size Abandoned runs - not collected runs Cancelled runs - cancelled Cluster vs local runs Reasons for failure = look in the err out? Metadata required: work directory for local and cluster tasks = from Helper or cmd parameter. WS names - enumeration. Status file names and content.

Author:

Peter Troshin, Alexander Sherstnev

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static java.text.SimpleDateFormat	DF
(package private) static java.io.FileFilter	directories
private static org.apache.log4j.Logger	log
private java.util.List<JobStat>	stats
private int	timeOutInHours Consider the job that has been working for longer than timeOutInHours completed, whatever the outcome
(package private) static int	UNDEFINED
private java.io.File	workingDirectory

Constructor Summary

Constructors

Constructor and Description
ExecutionStatCollector(java.lang.String workingDirectory, int timeOutInHours) List subdirectories in the job directory

Method Summary

Modifier and Type	Method and Description
(package private) void	collectStatistics()
(package private) StatProcessor	getStats()
(package private) boolean	hasCompleted(JobDirectory jd)
(package private) boolean	hasTimedOut(JobDirectory jd)
static void	main(java.lang.String[] args) Not in use
void	run()
(package private) void	writeStatToDB()

Methods inherited from class java.lang.Object

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

Field Detail

UNDEFINED

static final int UNDEFINED

See Also:

Constant Field Values

DF

static java.text.SimpleDateFormat DF

log

private static final org.apache.log4j.Logger log

workingDirectory

private final java.io.File workingDirectory

stats

private final java.util.List<JobStat> stats

timeOutInHours

private final int timeOutInHours

Consider the job that has been working for longer than timeOutInHours completed, whatever the outcome

directories

static java.io.FileFilter directories

Constructor Detail

ExecutionStatCollector

public ExecutionStatCollector(java.lang.String workingDirectory,
                              int timeOutInHours)

List subdirectories in the job directory

Parameters:

workingDirectory -

timeOutInHours -

Method Detail

hasCompleted

boolean hasCompleted(JobDirectory jd)

hasTimedOut

boolean hasTimedOut(JobDirectory jd)

getStats

StatProcessor getStats()

writeStatToDB

void writeStatToDB()
            throws java.sql.SQLException

Throws:

java.sql.SQLException

main

public static void main(java.lang.String[] args)
                 throws java.io.IOException,
                        java.sql.SQLException

Not in use

Throws:

java.io.IOException

java.sql.SQLException

collectStatistics

void collectStatistics()

run

public void run()

Specified by:

run in interface java.lang.Runnable