fact.datacorrection

Class CorrectPixelDelays

java.lang.Object

fact.datacorrection.CorrectPixelDelays

All Implemented Interfaces:

stream.Processor, stream.StatefulProcessor

public class CorrectPixelDelays
extends Object
implements stream.StatefulProcessor

This Processor corrects the Pixel-Delays read from a .csv file.

Author:

Maximilian Noethe <maximilian.noethe@tu-dortmund.de>

Field Summary

Fields

Modifier and Type	Field and Description
String	arrivalTimeKey
String	outputKey
stream.io.SourceURL	url

Constructor Summary

Constructors

Constructor and Description
CorrectPixelDelays()

Method Summary

Modifier and Type	Method and Description
void	finish()
void	init(stream.ProcessContext processContext)
stream.Data	process(stream.Data item)
void	resetState()

Methods inherited from class java.lang.Object

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

Field Detail

arrivalTimeKey

@Parameter(required=true,
           description="arrivalTime input")
public String arrivalTimeKey

outputKey

@Parameter(required=true,
           description="The name of the output")
public String outputKey

url

@Parameter(required=true,
           description="The url to the inputfiles for pixel Delays")
public stream.io.SourceURL url

Constructor Detail

CorrectPixelDelays

public CorrectPixelDelays()

Method Detail

process

public stream.Data process(stream.Data item)

Specified by:

process in interface stream.Processor

init

public void init(stream.ProcessContext processContext)
          throws Exception

Specified by:

init in interface stream.StatefulProcessor

Throws:

Exception

resetState

public void resetState()
                throws Exception

Specified by:

resetState in interface stream.StatefulProcessor

Throws:

Exception

finish

public void finish()
            throws Exception

Specified by:

finish in interface stream.StatefulProcessor

Throws:

Exception