public class StreamThroughput
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
StreamThroughput(java.lang.String statusMessagePrefix)
Construct a new StreamThroughput
|
StreamThroughput(java.lang.String statusMessagePrefix,
java.lang.String initialMessage,
Logger log)
Construct a new StreamThroughput
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
finished()
Register the end of measurement.
|
java.lang.String |
finished(Logger log)
Register the end of measurement.
|
int |
getAverageInstancesPerSecond()
Get the average instances per second
|
void |
setSamplePeriod(int period)
Set the sampling period (in milliseconds) to compute througput over
|
void |
updateEnd(Logger log)
Register a throughput measurement end point.
|
void |
updateStart()
Register a throughput measurement start point
|
public StreamThroughput(java.lang.String statusMessagePrefix)
statusMessagePrefix
- the unique identifier of the Knowledge Flow
component being measured. This enables the correct line in the
status area to be updated. See any Knowledge Flow step for an
example.public StreamThroughput(java.lang.String statusMessagePrefix, java.lang.String initialMessage, Logger log)
statusMessagePrefix
- the unique identifier of the Knowledge Flow
component being measured. This enables the correct line in the
status area to be updated. See any Knowledge Flow step for an
example.initialMessage
- an initial message to print to the status area for
this step on constructionlog
- the log to write status updates topublic void setSamplePeriod(int period)
period
- the sampling period in millisecondspublic void updateStart()
public void updateEnd(Logger log)
log
- the log to write status updates topublic int getAverageInstancesPerSecond()
public java.lang.String finished(Logger log)
log
- the log to write topublic java.lang.String finished()