|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.waveset.task.AbstractMonitor
com.waveset.task.ExtendedResultsMonitor
Allows an executing task to publish its progress and extended results without worrying about how these will be stored or displayed.
Field Summary | |
static java.lang.String |
code_id
|
Fields inherited from class com.waveset.task.AbstractMonitor |
_monitorError, _monitorInfo, _monitorProgress, _monitorWarning, _trace, trace |
Constructor Summary | |
ExtendedResultsMonitor(TaskContext ctx,
TaskInstance ti,
Executor exec)
|
|
ExtendedResultsMonitor(TaskContext ctx,
TaskInstance ti,
Executor exec,
java.util.List resultColumns)
|
Method Summary | |
boolean |
checkBreak()
Overrides AbstractMonitor.checkBreak()
to return true if terminate is requested. |
Executor |
getExecutor()
|
com.waveset.repository.Repository |
getRepository()
|
TaskContext |
getTaskContext()
|
TaskInstance |
getTaskInstance()
|
void |
monitorDeath(java.lang.Throwable throes)
A task must signal a fatal exception. |
void |
monitorDone(WavesetResult res)
A task must signal completion by returning its result. |
void |
monitorErrorData(java.lang.String s)
|
void |
monitorInputData(java.lang.String s)
|
void |
monitorMessage(Message msg)
|
void |
monitorOutputData(java.lang.String s)
|
void |
monitorOutputMsg(java.lang.String msg)
|
void |
monitorProgress(java.lang.String msg)
A task reports (terse) progress such as "Extracted 127 of 129 accounts read.". |
Methods inherited from class com.waveset.task.AbstractMonitor |
formatData, getProperty, monitorErrorData, monitorErrorData, monitorErrorMsg, monitorErrorMsg, monitorErrorMsg, monitorInputData, monitorInputData, monitorMessage, monitorOutputData, monitorOutputData, monitorOutputMsg, monitorWarningMsg, monitorWarningMsg, monitorWarningMsg, println, setMonitorProgress, setMonitorSeverity, setProperty, setTrace |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final java.lang.String code_id
Constructor Detail |
public ExtendedResultsMonitor(TaskContext ctx, TaskInstance ti, Executor exec) throws InvalidArgument, ConfigurationError, IOException
public ExtendedResultsMonitor(TaskContext ctx, TaskInstance ti, Executor exec, java.util.List resultColumns) throws InvalidArgument, ConfigurationError, IOException
resultColumns
- - overrides default columns.ResultRecord.DEFAULT_COLUMNS
,
ResultTable.setColumns(java.util.List)
Method Detail |
public TaskContext getTaskContext()
public com.waveset.repository.Repository getRepository()
public TaskInstance getTaskInstance()
public Executor getExecutor()
public boolean checkBreak()
AbstractMonitor.checkBreak()
to return true
if terminate is requested.
checkBreak
in interface Monitor
checkBreak
in class AbstractMonitor
public void monitorInputData(java.lang.String s)
monitorInputData
in interface Monitor
monitorInputData
in class AbstractMonitor
public void monitorOutputData(java.lang.String s)
monitorOutputData
in interface Monitor
monitorOutputData
in class AbstractMonitor
public void monitorOutputMsg(java.lang.String msg)
monitorOutputMsg
in interface Monitor
monitorOutputMsg
in class AbstractMonitor
public void monitorErrorData(java.lang.String s)
monitorErrorData
in interface Monitor
monitorErrorData
in class AbstractMonitor
public void monitorMessage(Message msg)
monitorMessage
in class AbstractMonitor
public void monitorProgress(java.lang.String msg)
This information is placed in the persistent task instance so that summary status information is available from any server in a load-balanced environment.
monitorProgress
in interface Monitor
monitorProgress
in class AbstractMonitor
public void monitorDone(WavesetResult res)
Monitor
monitorDone
in interface Monitor
monitorDone
in class AbstractMonitor
public void monitorDeath(java.lang.Throwable throes)
Monitor
This allows the monitor to free any resources, as well as to report the untimely death of the subject task in a standard way.
monitorDeath
in interface Monitor
monitorDeath
in class AbstractMonitor
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |