public abstract class AbstractAnalyzeJob
extends java.lang.Object
implements java.util.concurrent.Callable<java.lang.Boolean>
Modifier and Type | Field and Description |
---|---|
protected static int |
DEFAULT_IDLE_PERIOD |
protected static int |
DEFAULT_MAX_ITERATION_PER_TRANSACTION |
protected static java.lang.String |
IDLE_PROPERTY |
protected static java.lang.String |
MAX_ITERATION_PER_TRANSACTION_PROPERTY |
Constructor and Description |
---|
AbstractAnalyzeJob(Interval interval,
java.io.File eventDirectory,
StatisticContext context,
java.util.List<AbstractStatisticAgent> agentList,
ProgressListener listener) |
Modifier and Type | Method and Description |
---|---|
java.lang.Boolean |
call() |
java.util.List<AbstractStatisticAgent> |
getAgentList() |
StatisticContext |
getContext() |
protected int |
getIdlePeriod() |
ProgressListener |
getListener() |
protected int |
getMaxIterationPerTransaction() |
protected static AbstractReportMetric |
getReportMetric(Workspace analyzedWS,
StatisticContext context,
java.lang.Class<? extends AbstractReportMetric> clazz) |
protected static AbstractReportMetric |
getReportMetric(Workspace analyzedWS,
StatisticContext context,
java.util.Date startDate,
java.util.Date endDate,
java.lang.Class<? extends AbstractReportMetric> clazz) |
protected void |
readEventFile(MonitoredInputStream inputStream)
Read
EventData from a file and call every agent to process it |
void |
setAgentList(java.util.List<AbstractStatisticAgent> agentList) |
void |
setContext(StatisticContext context) |
void |
setListener(ProgressListener listener) |
protected static final int DEFAULT_MAX_ITERATION_PER_TRANSACTION
protected static final int DEFAULT_IDLE_PERIOD
protected static final java.lang.String MAX_ITERATION_PER_TRANSACTION_PROPERTY
protected static final java.lang.String IDLE_PROPERTY
public AbstractAnalyzeJob(Interval interval, java.io.File eventDirectory, StatisticContext context, java.util.List<AbstractStatisticAgent> agentList, ProgressListener listener)
public StatisticContext getContext()
public void setContext(StatisticContext context)
public java.util.List<AbstractStatisticAgent> getAgentList()
public void setAgentList(java.util.List<AbstractStatisticAgent> agentList)
public ProgressListener getListener()
public void setListener(ProgressListener listener)
public java.lang.Boolean call()
call
in interface java.util.concurrent.Callable<java.lang.Boolean>
protected void readEventFile(MonitoredInputStream inputStream) throws java.lang.Exception
EventData
from a file and call every agent to process itinputStream
- the MonitoredInputStream
of the current filejava.lang.Exception
- Exception thrown when reading the fileprotected static AbstractReportMetric getReportMetric(Workspace analyzedWS, StatisticContext context, java.lang.Class<? extends AbstractReportMetric> clazz) throws java.lang.InstantiationException, java.lang.IllegalAccessException
java.lang.InstantiationException
java.lang.IllegalAccessException
protected static AbstractReportMetric getReportMetric(Workspace analyzedWS, StatisticContext context, java.util.Date startDate, java.util.Date endDate, java.lang.Class<? extends AbstractReportMetric> clazz) throws java.lang.InstantiationException, java.lang.IllegalAccessException
java.lang.InstantiationException
java.lang.IllegalAccessException
protected int getIdlePeriod()
protected int getMaxIterationPerTransaction()
Copyright © 2001-2010 Jalios SA. All Rights Reserved.