fact.datacorrection

Class PatchJumpRemoval

java.lang.Object

fact.datacorrection.PatchJumpRemoval

All Implemented Interfaces:

stream.Processor

public class PatchJumpRemoval
extends Object
implements stream.Processor

Removes artificial effects called "jumps" on a per patch basis. TODO: Refactor previous startcell stuff to be put into a container class

Author:

Fabian Temme

Field Summary

Fields

Modifier and Type	Field and Description
String	dataKey
double	jumpLimit
String	outputJumpsKey
String	outputKey
String	prevEventsKey
String	startCellKey
String	unixTimeKey

Constructor Summary

Constructors

Constructor and Description
PatchJumpRemoval()

Method Summary

Modifier and Type	Method and Description
double	checkForJump(int patch, int pos, double[] derivation, boolean isStartCell) Checks if there is a jump from the slices pos to pos+1
double	checkForRingingFFT(int patch, int pos, double[] dataArray, double[] derivation, double jumpHeight, JumpInfos jumpInfos) First check if there is a significant ringing in the dataArray, by performing a FFT on the dataArray, and checking the amplitude of the frequency bins between 0.18 GHz and 0.22 GHz.
boolean	checkForSignalFlank(int patch, int pos, double[] derivation, boolean isStartCell, double jumpHeight) Checks if the detected jumps comes from a photon signal flank
boolean	checkForTimeDependency(int patch, double deltaT, double jumpHeight, JumpInfos jumpInfos) Checks if the jumpHeight is in the range of the predicted jumpHeight, depending on deltaT
double[]	correctJump(int patch, int pos, boolean isStartCell, double[] result, double jumpHeight) Correct the data array for a jump.
void	createPatchAverage(int patch, double[] patchAverage, double[] patchDerivationAverage, double[] result) Calculates the average of the result data array for a given patch.
double[]	HandleSpike(int patch, int pos, double[] result, JumpInfos jumpInfo) Checks if there are spikes directly in front of the jump and/or after the jump.
stream.Data	process(stream.Data item)

Methods inherited from class java.lang.Object

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

Field Detail

dataKey

@Parameter(required=true)
public String dataKey

outputKey

@Parameter(required=true)
public String outputKey

outputJumpsKey

@Parameter(required=false,
           description="Useful for jump studies")
public String outputJumpsKey

prevEventsKey

@Parameter(required=true)
public String prevEventsKey

startCellKey

@Parameter(required=true)
public String startCellKey

unixTimeKey

@Parameter(required=false,
           description="The key containing the UnixTimeUTC")
public String unixTimeKey

jumpLimit

@Parameter
public double jumpLimit

Constructor Detail

PatchJumpRemoval

public PatchJumpRemoval()

Method Detail

process

public stream.Data process(stream.Data item)

Specified by:

process in interface stream.Processor

HandleSpike

public double[] HandleSpike(int patch,
                            int pos,
                            double[] result,
                            JumpInfos jumpInfo)

Checks if there are spikes directly in front of the jump and/or after the jump. Correct this jump if necessary

Parameters:

patch -

pos -

Returns:

createPatchAverage

public void createPatchAverage(int patch,
                               double[] patchAverage,
                               double[] patchDerivationAverage,
                               double[] result)

Calculates the average of the result data array for a given patch. Also calulates the derivation of this patch average. The timemarker channels are excluded from the averaging

Parameters:

patch -

patchAverage -

patchDerivationAverage -

checkForJump

public double checkForJump(int patch,
                           int pos,
                           double[] derivation,
                           boolean isStartCell)

Checks if there is a jump from the slices pos to pos+1

Parameters:

patch -

pos -

derivation -

isStartCell -

Returns:

checkForTimeDependency

public boolean checkForTimeDependency(int patch,
                                      double deltaT,
                                      double jumpHeight,
                                      JumpInfos jumpInfos)

Checks if the jumpHeight is in the range of the predicted jumpHeight, depending on deltaT

Parameters:

patch -

deltaT -

jumpHeight -

jumpInfos -

Returns:

checkForSignalFlank

public boolean checkForSignalFlank(int patch,
                                   int pos,
                                   double[] derivation,
                                   boolean isStartCell,
                                   double jumpHeight)

Checks if the detected jumps comes from a photon signal flank

Parameters:

patch -

pos -

derivation -

isStartCell -

Returns:

checkForRingingFFT

public double checkForRingingFFT(int patch,
                                 int pos,
                                 double[] dataArray,
                                 double[] derivation,
                                 double jumpHeight,
                                 JumpInfos jumpInfos)

First check if there is a significant ringing in the dataArray, by performing a FFT on the dataArray, and checking the amplitude of the frequency bins between 0.18 GHz and 0.22 GHz. If there is ringing, reduce the jumpHeight by the average of the derivation one period of the ringing before and one period after the jump. Return false if the resulting jumpHeight is smaller than the jumpLimit, and true if it is higher or no ringing was found.

Parameters:

patch -

pos -

dataArray -

derivation -

Returns:

correctJump

public double[] correctJump(int patch,
                            int pos,
                            boolean isStartCell,
                            double[] result,
                            double jumpHeight)

Correct the data array for a jump. In case of a jump at a previous start cells, all slices beginning with pos+1 are reduced about the jump height, in case of a jump at a previous stopp cell, all slices up to pos are reduced about the jump height.

Parameters:

patch -

pos -

isStartCell -

result -

jumpHeight -

Returns: