dive4elements/river: flys-artifacts/src/main/java/de/intevation/flys/artifacts/model/fixings/FixCalculation.java annotate

annotate flys-artifacts/src/main/java/de/intevation/flys/artifacts/model/fixings/FixCalculation.java @ 3107:cbf308f5c41b

FixA: Store the standard deviation of delta Ws of reference points into parameters, too. flys-artifacts/trunk@4706 c6561f87-3c4e-4783-a992-168aeb5c3f6f

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Tue, 19 Jun 2012 15:28:40 +0000
parents	23de6d678fba
children	0b86b005bb9a

rev	line source
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1 package de.intevation.flys.artifacts.model.fixings;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	2
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	3 import de.intevation.flys.artifacts.FixationArtifactAccess;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	4
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	5 import de.intevation.flys.artifacts.math.fitting.Function;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	6 import de.intevation.flys.artifacts.math.fitting.FunctionFactory;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	7
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	8 import de.intevation.flys.artifacts.model.Calculation;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	9 import de.intevation.flys.artifacts.model.CalculationResult;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10 import de.intevation.flys.artifacts.model.FixingsColumn;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	11 import de.intevation.flys.artifacts.model.FixingsColumnFactory;
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	12
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	13 import de.intevation.flys.artifacts.model.FixingsOverview.AndFilter;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	14 import de.intevation.flys.artifacts.model.FixingsOverview.DateRangeFilter;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	15 import de.intevation.flys.artifacts.model.FixingsOverview.Fixing;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	16 import de.intevation.flys.artifacts.model.FixingsOverview.IdFilter;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	17 import de.intevation.flys.artifacts.model.FixingsOverview.KmFilter;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	18 import de.intevation.flys.artifacts.model.FixingsOverview.Range;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	19 import de.intevation.flys.artifacts.model.FixingsOverview.SectorRangeFilter;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	20 import de.intevation.flys.artifacts.model.FixingsOverview.SectorFilter;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	21
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	22 import de.intevation.flys.artifacts.model.FixingsOverview;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	23 import de.intevation.flys.artifacts.model.FixingsOverviewFactory;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	24 import de.intevation.flys.artifacts.model.Parameters;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	25
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	26 import de.intevation.flys.utils.DateAverager;
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	27 import de.intevation.flys.utils.DoubleUtil;
3014 e341606faeb4 FixA: Use KMIndex for outliers. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3011 diff changeset	28 import de.intevation.flys.utils.KMIndex;
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	29
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	30 import java.util.ArrayList;
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	31 import java.util.Date;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	32 import java.util.HashMap;
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	33 import java.util.List;
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	34 import java.util.Map;
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	35
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	36 import org.apache.log4j.Logger;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	37
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	38 public class FixCalculation
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	39 extends Calculation
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	40 {
2786 f9e62e76ee1f FixA: Return correct data structure from calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2783 diff changeset	41 private static Logger log = Logger.getLogger(FixCalculation.class);
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	42
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	43 public static final double EPSILON = 1e-4;
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	44
3003 e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	45 protected String river;
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	46 protected double from;
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	47 protected double to;
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	48 protected double step;
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	49 protected boolean preprocessing;
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	50 protected String function;
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	51 protected int [] events;
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	52 protected DateRange [] analysisPeriods;
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	53 protected int qSectorStart;
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	54 protected int qSectorEnd;
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	55
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	56 public FixCalculation() {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	57 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	58
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	59 public FixCalculation(FixationArtifactAccess access) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	60
3003 e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	61 String river = access.getRiver();
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	62 Double from = access.getFrom();
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	63 Double to = access.getTo();
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	64 Double step = access.getStep();
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	65 String function = access.getFunction();
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	66 int [] events = access.getEvents();
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	67 DateRange [] analysisPeriods = access.getAnalysisPeriods();
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	68 Integer qSectorStart = access.getQSectorStart();
e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	69 Integer qSectorEnd = access.getQSectorEnd();
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	70 Boolean preprocessing = access.getPreprocessing();
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	71
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	72 if (river == null) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	73 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	74 addProblem("fix.missing.river");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	75 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	76
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	77 if (from == null) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	78 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	79 addProblem("fix.missing.from");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	80 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	81
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	82 if (to == null) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	83 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	84 addProblem("fix.missing.to");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	85 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	86
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	87 if (step == null) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	88 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	89 addProblem("fix.missing.step");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	90 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	91
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	92 if (function == null) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	93 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	94 addProblem("fix.missing.function");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	95 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	96
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	97 if (events == null \|\| events.length < 1) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	98 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	99 addProblem("fix.missing.events");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	100 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	101
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	102 if (analysisPeriods == null \|\| analysisPeriods.length < 1) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	103 // TODO: i18n
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	104 addProblem("fix.missing.analysis.periods");
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	105 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	106
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	107 if (qSectorStart == null) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	108 // TODO: i18n
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	109 addProblem("fix.missing.qstart.sector");
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	110 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	111
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	112 if (qSectorEnd == null) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	113 // TODO: i18n
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	114 addProblem("fix.missing.qend.sector");
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	115 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	116
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	117 if (preprocessing == null) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	118 // TODO: i18n
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	119 addProblem("fix.missing.preprocessing");
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	120 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	121
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	122 if (!hasProblems()) {
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	123 this.river = river;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	124 this.from = from;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	125 this.to = to;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	126 this.step = step;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	127 this.function = function;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	128 this.events = events;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	129 this.analysisPeriods = analysisPeriods;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	130 this.qSectorStart = qSectorStart;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	131 this.qSectorEnd = qSectorEnd;
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	132 this.preprocessing = preprocessing;
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	133 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	134 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	135
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	136 public CalculationResult calculate() {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	137
2992 0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	138 boolean debug = log.isDebugEnabled();
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	139
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	140 FixingsOverview overview =
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	141 FixingsOverviewFactory.getOverview(river);
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	142
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	143 if (overview == null) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	144 addProblem("fix.no.overview.available");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	145 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	146
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	147 Function func = FunctionFactory.getInstance()
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	148 .getFunction(function);
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	149
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	150 if (func == null) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	151 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	152 addProblem("fix.invalid.function.name");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	153 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	154
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	155 if (hasProblems()) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	156 return new CalculationResult(this);
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	157 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	158
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	159 final List<Column> eventColumns = getEventColumns(overview);
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	160
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	161 if (eventColumns.size() < 2) {
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	162 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	163 addProblem("fix.too.less.data.columns");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	164 return new CalculationResult(this);
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	165 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	166
2992 0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	167 double [] kms = DoubleUtil.explode(from, to, step / 1000.0);
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	168
3106 23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	169 final double [] qs = new double[eventColumns.size()];
23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	170 final double [] ws = new double[qs.length];
23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	171 final boolean [] interpolated = new boolean[ws.length];
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	172
3096 d7b0f52d6d04 FixA: Calculate Delta W(t) for reference points, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3076 diff changeset	173 Fitting.QWDFactory qwdFactory = new Fitting.QWDFactory() {
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	174 @Override
3096 d7b0f52d6d04 FixA: Calculate Delta W(t) for reference points, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3076 diff changeset	175 public QWD create(double q, double w) {
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	176 // Check all the event columns for close match
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	177 // and take the description and the date from meta.
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	178 for (int i = 0; i < qs.length; ++i) {
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	179 if (Math.abs(qs[i]-q) < EPSILON
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	180 && Math.abs(ws[i]-w) < EPSILON) {
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	181 Column column = eventColumns.get(i);
3096 d7b0f52d6d04 FixA: Calculate Delta W(t) for reference points, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3076 diff changeset	182 return new QWD(
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	183 q, w,
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	184 column.getDescription(),
3096 d7b0f52d6d04 FixA: Calculate Delta W(t) for reference points, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3076 diff changeset	185 column.getDate(),
3106 23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	186 interpolated[i],
3096 d7b0f52d6d04 FixA: Calculate Delta W(t) for reference points, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3076 diff changeset	187 0d);
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	188 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	189 }
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	190 log.warn("cannot find column for (" + q + ", " + w + ")");
3096 d7b0f52d6d04 FixA: Calculate Delta W(t) for reference points, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3076 diff changeset	191 return new QWD(q, w);
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	192 }
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	193 };
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	194
3096 d7b0f52d6d04 FixA: Calculate Delta W(t) for reference points, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3076 diff changeset	195 Fitting fitting = new Fitting(func, qwdFactory, preprocessing);
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	196
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	197 String [] parameterNames = func.getParameterNames();
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	198
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	199 Parameters results =
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	200 new Parameters(createColumnNames(parameterNames));
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	201
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	202 boolean invalid = false;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	203
2992 0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	204 if (debug) {
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	205 log.debug("number of kms: " + kms.length);
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	206 }
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	207
3096 d7b0f52d6d04 FixA: Calculate Delta W(t) for reference points, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3076 diff changeset	208 KMIndex<QW []> outliers = new KMIndex<QW []>();
d7b0f52d6d04 FixA: Calculate Delta W(t) for reference points, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3076 diff changeset	209 KMIndex<QWD []> referenced = new KMIndex<QWD []>(kms.length);
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	210
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	211 int kmIndex = results.columnIndex("km");
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	212 int chiSqrIndex = results.columnIndex("chi_sqr");
3065 ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	213 int maxQIndex = results.columnIndex("max_q");
3107 cbf308f5c41b FixA: Store the standard deviation of delta Ws of reference points into parameters, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3106 diff changeset	214 int stdDevIndex = results.columnIndex("std-dev");
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	215 int [] parameterIndices = results.columnIndices(parameterNames);
3010 05a3fe8800b3 FixA: Store Chi^2 of fitting into result, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3008 diff changeset	216
2992 0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	217 int numFailed = 0;
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	218
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	219 for (int i = 0; i < kms.length; ++i) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	220 double km = kms[i];
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	221
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	222 // Fill Qs and Ws from event columns.
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	223 for (int j = 0; j < ws.length; ++j) {
3106 23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	224 interpolated[j] = eventColumns.get(j).getQW(km, qs, ws, j);
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	225 // TODO: mark as interpolated.
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	226 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	227
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	228 fitting.reset();
3010 05a3fe8800b3 FixA: Store Chi^2 of fitting into result, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3008 diff changeset	229
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	230 if (!fitting.fit(qs, ws)) {
2992 0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	231 ++numFailed;
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	232 // TODO: i18n
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	233 addProblem(km, "fix.fitting.failed");
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	234 continue;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	235 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	236
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	237 referenced.add(km, fitting.referencedToArray());
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	238
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	239 if (fitting.hasOutliers()) {
3014 e341606faeb4 FixA: Use KMIndex for outliers. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3011 diff changeset	240 outliers.add(km, fitting.outliersToArray());
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	241 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	242
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	243 int row = results.newRow();
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	244
3010 05a3fe8800b3 FixA: Store Chi^2 of fitting into result, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3008 diff changeset	245 results.set(row, kmIndex, km);
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	246 results.set(row, chiSqrIndex, fitting.getChiSquare());
3107 cbf308f5c41b FixA: Store the standard deviation of delta Ws of reference points into parameters, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3106 diff changeset	247 results.set(row, stdDevIndex, fitting.getStandardDeviation());
cbf308f5c41b FixA: Store the standard deviation of delta Ws of reference points into parameters, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3106 diff changeset	248 results.set(row, maxQIndex, fitting.getMaxQ());
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	249 invalid \|= results.set(
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	250 row, parameterIndices, fitting.getParameters());
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	251 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	252
2992 0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	253 if (debug) {
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	254 log.debug("success: " + (kms.length - numFailed));
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	255 log.debug("failed: " + numFailed);
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	256 }
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	257
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	258 if (invalid) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	259 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	260 addProblem("fix.invalid.values");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	261 results.removeNaNs();
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	262 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	263
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	264 KMIndex<AnalysisPeriod []> analysisPeriods =
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	265 calculateAnalysisPeriods(func, results, overview);
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	266
3014 e341606faeb4 FixA: Use KMIndex for outliers. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3011 diff changeset	267 outliers.sort();
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	268 referenced.sort();
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	269 analysisPeriods.sort();
3014 e341606faeb4 FixA: Use KMIndex for outliers. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3011 diff changeset	270
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	271 FixResult fr = new FixResult(
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	272 results,
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	273 referenced, outliers,
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	274 analysisPeriods);
2786 f9e62e76ee1f FixA: Return correct data structure from calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2783 diff changeset	275
f9e62e76ee1f FixA: Return correct data structure from calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2783 diff changeset	276 return new CalculationResult(fr, this);
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	277 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	278
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	279
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	280 protected List<Column> getEventColumns(FixingsOverview overview) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	281
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	282 FixingsColumnFactory fcf = FixingsColumnFactory.getInstance();
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	283
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	284 List<Column> columns = new ArrayList<Column>(events.length);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	285
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	286 for (int eventId: events) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	287 IdFilter idFilter = new IdFilter(eventId);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	288
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	289 List<Fixing.Column> metas = overview.filter(null, idFilter);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	290
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	291 if (metas.isEmpty()) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	292 // TODO: i18n
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	293 addProblem("fix.missing.column", eventId);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	294 continue;
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	295 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	296
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	297 FixingsColumn data = fcf.getColumnData(metas.get(0));
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	298 if (data == null) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	299 // TODO: i18n
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	300 addProblem("fix.cannot.load.data", eventId);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	301 continue;
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	302 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	303
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	304 columns.add(new Column(metas.get(0), data));
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	305 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	306
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	307 return columns;
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	308 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	309
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	310 protected KMIndex<AnalysisPeriod []> calculateAnalysisPeriods(
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	311 Function function,
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	312 Parameters parameters,
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	313 FixingsOverview overview
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	314 ) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	315 Range range = new Range(from, to);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	316
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	317 int kmIndex = parameters.columnIndex("km");
3065 ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	318 int maxQIndex = parameters.columnIndex("max_q");
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	319
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	320 ColumnCache cc = new ColumnCache();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	321
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	322 double [] wq = new double[2];
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	323
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	324 int [] parameterIndices =
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	325 parameters.columnIndices(function.getParameterNames());
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	326
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	327 double [] parameterValues = new double[parameterIndices.length];
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	328
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	329 DateAverager dateAverager = new DateAverager();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	330
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	331 KMIndex<AnalysisPeriod []> results =
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	332 new KMIndex<AnalysisPeriod []>(parameters.size());
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	333
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	334 for (int row = 0, R = parameters.size(); row < R; ++row) {
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	335 double km = parameters.get(row, kmIndex);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	336 parameters.get(row, parameterIndices, parameterValues);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	337
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	338 // This is the paraterized function for a given km.
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	339 de.intevation.flys.artifacts.math.Function instance =
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	340 function.instantiate(parameterValues);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	341
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	342 KmFilter kmFilter = new KmFilter(km);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	343
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	344 ArrayList<AnalysisPeriod> periodResults =
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	345 new ArrayList<AnalysisPeriod>(analysisPeriods.length);
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	346
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	347 for (DateRange analysisPeriod: analysisPeriods) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	348 DateRangeFilter drf = new DateRangeFilter(
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	349 analysisPeriod.getFrom(),
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	350 analysisPeriod.getTo());
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	351
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	352 QWD [] qSectorAverages = new QWD[4];
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	353 ArrayList<QWD> allQWDs = new ArrayList<QWD>();
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	354
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	355 // for all Q sectors.
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	356 for (int qSector = qSectorStart; qSector < qSectorEnd; ++qSector) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	357
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	358 AndFilter filter = new AndFilter();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	359 filter.add(kmFilter);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	360 filter.add(new SectorFilter(qSector));
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	361 filter.add(drf);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	362
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	363 List<Fixing.Column> metas = overview.filter(range, filter);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	364
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	365 if (metas.isEmpty()) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	366 // No fixings for km and analysis period
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	367 continue;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	368 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	369
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	370 double sumQ = 0.0;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	371 double sumW = 0.0;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	372
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	373 List<QWD> qwds = new ArrayList<QWD>(metas.size());
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	374
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	375 dateAverager.clear();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	376
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	377 for (Fixing.Column meta: metas) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	378 if (meta.findQSector(km) != qSector) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	379 // Ignore not matching sectors.
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	380 continue;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	381 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	382
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	383 Column column = cc.getColumn(meta);
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	384 if (column == null \|\| !column.getQW(km, wq)) {
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	385 continue;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	386 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	387
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	388 double fw = instance.value(wq[1]);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	389 if (Double.isNaN(fw)) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	390 continue;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	391 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	392
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	393 double dw = (wq[0] - fw)*100.0;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	394
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	395 Date date = column.getDate();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	396 String description = column.getDescription();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	397
3106 23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	398 QWD qwd = new QWD(
23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	399 wq[1], wq[0], description, date, true, dw);
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	400
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	401 qwds.add(qwd);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	402
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	403 sumW += wq[0];
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	404 sumQ += wq[1];
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	405
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	406 dateAverager.add(date);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	407 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	408
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	409 // Calulate average per Q sector.
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	410 int N = qwds.size();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	411 if (N > 0) {
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	412 allQWDs.addAll(qwds);
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	413 double avgW = sumW / N;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	414 double avgQ = sumQ / N;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	415
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	416 double avgFw = instance.value(avgQ);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	417 if (!Double.isNaN(avgFw)) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	418 double avgDw = (avgW - avgFw)*100.0;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	419 Date avgDate = dateAverager.getAverage();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	420
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	421 String avgDescription = "avg.deltawt." + qSector;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	422
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	423 QWD avgQWD = new QWD(
3106 23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	424 avgQ, avgW, avgDescription, avgDate, true, avgDw);
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	425
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	426 qSectorAverages[qSector] = avgQWD;
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	427 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	428 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	429 } // for all Q sectors
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	430
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	431 QWD [] aqwds = allQWDs.toArray(new QWD[allQWDs.size()]);
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	432
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	433 AnalysisPeriod periodResult = new AnalysisPeriod(
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	434 analysisPeriod, aqwds, qSectorAverages);
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	435 periodResults.add(periodResult);
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	436 }
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	437
3065 ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	438 double maxQ = -Double.MAX_VALUE;
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	439 for (AnalysisPeriod ap: periodResults) {
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	440 double q = ap.getMaxQ();
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	441 if (q > maxQ) {
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	442 maxQ = q;
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	443 }
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	444 }
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	445
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	446 double oldMaxQ = parameters.get(row, maxQIndex);
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	447 if (oldMaxQ < maxQ) {
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	448 parameters.set(row, maxQIndex, maxQ);
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	449 }
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	450
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	451 results.add(km, periodResults.toArray(
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	452 new AnalysisPeriod[periodResults.size()]));
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	453 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	454
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	455 return results;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	456 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	457
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	458 /** Helper class to bundle the meta information of a column
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	459 * and the real data.
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	460 */
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	461 protected static class Column {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	462
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	463 protected Fixing.Column meta;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	464 protected FixingsColumn data;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	465
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	466 public Column() {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	467 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	468
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	469 public Column(Fixing.Column meta, FixingsColumn data) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	470 this.meta = meta;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	471 this.data = data;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	472 }
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	473
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	474 public Date getDate() {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	475 return meta.getStartTime();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	476 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	477
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	478 public String getDescription() {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	479 return meta.getDescription();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	480 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	481
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	482 public boolean getQW(
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	483 double km,
5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	484 double [] qs,
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	485 double [] ws,
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	486 int index
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	487 ) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	488 qs[index] = data.getQ(km);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	489 return data.getW(km, ws, index);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	490 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	491
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	492 public boolean getQW(double km, double [] wq) {
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	493 data.getW(km, wq, 0);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	494 if (Double.isNaN(wq[0])) return false;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	495 wq[1] = data.getQ(km);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	496 return !Double.isNaN(wq[1]);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	497 }
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	498 } // class Column
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	499
3008 9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	500
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	501 /**
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	502 * Helper class to find the data belonging to meta info more quickly.
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	503 */
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	504 public static class ColumnCache {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	505
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	506 protected Map<Integer, Column> columns;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	507
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	508 public ColumnCache() {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	509 columns = new HashMap<Integer, Column>();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	510 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	511
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	512 public Column getColumn(Fixing.Column meta) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	513 Integer key = meta.getId();
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	514 Column column = columns.get(key);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	515 if (column == null) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	516 FixingsColumn data = FixingsColumnFactory
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	517 .getInstance()
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	518 .getColumnData(meta);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	519 if (data != null) {
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	520 column = new Column(meta, data);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	521 columns.put(key, column);
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	522 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	523 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	524 return column;
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	525 }
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	526 } // class ColumnCache
9e0500d64524 FixA: Calculate the Delta W/ts + the average Delta W/ts per Q sector per analysis period. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3003 diff changeset	527
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	528 /** Fetch meta and data columns for analysis periods. */
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	529 protected Column [][] getAnalysisColumns(FixingsOverview overview) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	530
2993 70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	531 boolean debug = log.isDebugEnabled();
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	532 if (debug) {
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	533 log.debug("number analysis periods: " + analysisPeriods.length);
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	534 }
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	535
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	536 Column columns [][] = new Column[analysisPeriods.length][];
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	537
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	538 Range range = new Range(from, to);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	539 SectorRangeFilter sectorRangeFilter =
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	540 new SectorRangeFilter(qSectorStart, qSectorEnd);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	541
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	542 FixingsColumnFactory fcf = FixingsColumnFactory.getInstance();
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	543
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	544 for (int i = 0; i < columns.length; ++i) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	545
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	546 // Construct filter for period.
3003 e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	547 DateRange period = analysisPeriods[i];
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	548
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	549 AndFilter filter = new AndFilter();
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	550
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	551 DateRangeFilter dateRangeFilter =
3003 e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	552 new DateRangeFilter(period.getFrom(), period.getTo());
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	553
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	554 filter.add(dateRangeFilter);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	555 filter.add(sectorRangeFilter);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	556
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	557 List<Fixing.Column> metaCols = overview.filter(range, filter);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	558
2993 70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	559 if (debug) {
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	560 log.debug("number of filtered columns: " + metaCols.size());
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	561 }
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	562
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	563 ArrayList<Column> cols = new ArrayList<Column>(metaCols.size());
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	564
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	565 // Only use columns which have data.
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	566 for (Fixing.Column meta: metaCols) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	567 FixingsColumn data = fcf.getColumnData(meta);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	568 if (data != null) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	569 cols.add(new Column(meta, data));
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	570 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	571 }
2993 70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	572
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	573 if (debug) {
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	574 log.debug("failed loading: " + (metaCols.size()-cols.size()));
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	575 }
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	576 columns[i] = cols.toArray(new Column[cols.size()]);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	577 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	578
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	579 return columns;
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	580 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	581
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	582 protected static String [] createColumnNames(String [] parameters) {
3107 cbf308f5c41b FixA: Store the standard deviation of delta Ws of reference points into parameters, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3106 diff changeset	583 String [] result = new String[parameters.length + 4];
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	584 result[0] = "km";
3029 fa5d5b48028a FixA: Fixed index problem with name of chi^2. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3022 diff changeset	585 result[1] = "chi_sqr";
3065 ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	586 result[2] = "max_q";
3107 cbf308f5c41b FixA: Store the standard deviation of delta Ws of reference points into parameters, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3106 diff changeset	587 result[3] = "std-dev";
cbf308f5c41b FixA: Store the standard deviation of delta Ws of reference points into parameters, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3106 diff changeset	588 System.arraycopy(parameters, 0, result, 4, parameters.length);
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	589 return result;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	590 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	591 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	592 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > river

annotate flys-artifacts/src/main/java/de/intevation/flys/artifacts/model/fixings/FixCalculation.java @ 3107:cbf308f5c41b