fact

Class PerformanceMeasuringProcess

java.lang.Object

stream.runtime.AbstractProcess

stream.runtime.DefaultProcess

fact.PerformanceMeasuringProcess

All Implemented Interfaces:

stream.Process

public class PerformanceMeasuringProcess
extends stream.runtime.DefaultProcess

This process is a replacement for the standard process from the streams library which computes statistics about the runtime of each processor it calls.

You can use it like this:

The output will be written to the json file specified by the url parameter.

Created by Alexey and Kai on 27.05.15.

Field Summary

Fields

Modifier and Type	Field and Description
stream.io.SourceURL	url
int	warmupIterations

Fields inherited from class stream.runtime.AbstractProcess

onError, parentContext, priority, processContext, processors, properties, sink, source

Constructor Summary

Constructors

Constructor and Description
PerformanceMeasuringProcess()

Method Summary

Modifier and Type	Method and Description
void	finish()
void	init(stream.runtime.ApplicationContext context)
stream.Data	process(stream.Data data)

Methods inherited from class stream.runtime.AbstractProcess

add, execute, getContext, getId, getInput, getOnError, getOutput, getPriority, getProcessors, getProperties, remove, setId, setInput, setOnError, setOutput, setPriority, toString

Methods inherited from class java.lang.Object

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

Field Detail

url

@Parameter(required=false,
           description="Url to the .json file where the performance numbers are stored")
public stream.io.SourceURL url

warmupIterations

@Parameter(required=false,
           description="Number of warmup iterations to be performed before measuring time")
public int warmupIterations

Constructor Detail

PerformanceMeasuringProcess

public PerformanceMeasuringProcess()

Method Detail

init

public void init(stream.runtime.ApplicationContext context)
          throws Exception

Specified by:

init in interface stream.Process

Overrides:

init in class stream.runtime.AbstractProcess

Throws:

Exception

process

public stream.Data process(stream.Data data)

Overrides:

process in class stream.runtime.AbstractProcess

finish

public void finish()
            throws Exception

Specified by:

finish in interface stream.Process

Overrides:

finish in class stream.runtime.AbstractProcess

Throws:

Exception