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 @ 3106:23de6d678fba

FixA: Store into QWs if they are interpolated. flys-artifacts/trunk@4705 c6561f87-3c4e-4783-a992-168aeb5c3f6f

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Tue, 19 Jun 2012 14:01:47 +0000
parents	d7b0f52d6d04
children	cbf308f5c41b

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");
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	214 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	215
2992 0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	216 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	217
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	218 for (int i = 0; i < kms.length; ++i) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	219 double km = kms[i];
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	220
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	221 // Fill Qs and Ws from event columns.
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	222 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	223 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	224 // TODO: mark as interpolated.
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	225 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	226
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	227 fitting.reset();
3010 05a3fe8800b3 FixA: Store Chi^2 of fitting into result, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3008 diff changeset	228
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	229 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	230 ++numFailed;
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	231 // TODO: i18n
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	232 addProblem(km, "fix.fitting.failed");
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	233 continue;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	234 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	235
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	236 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	237
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	238 if (fitting.hasOutliers()) {
3014 e341606faeb4 FixA: Use KMIndex for outliers. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3011 diff changeset	239 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	240 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	241
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	242 int row = results.newRow();
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	243
3010 05a3fe8800b3 FixA: Store Chi^2 of fitting into result, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3008 diff changeset	244 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	245 results.set(row, chiSqrIndex, fitting.getChiSquare());
3065 ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	246 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	247 invalid \|= results.set(
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	248 row, parameterIndices, fitting.getParameters());
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	249 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	250
2992 0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	251 if (debug) {
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	252 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	253 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	254 }
0abdede5a0b8 FixA: Added facet to return delta w/t as CSV Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2788 diff changeset	255
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	256 if (invalid) {
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	257 // TODO: i18n
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	258 addProblem("fix.invalid.values");
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	259 results.removeNaNs();
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	260 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	261
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	262 KMIndex<AnalysisPeriod []> analysisPeriods =
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	263 calculateAnalysisPeriods(func, results, overview);
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	264
3014 e341606faeb4 FixA: Use KMIndex for outliers. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3011 diff changeset	265 outliers.sort();
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	266 referenced.sort();
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	267 analysisPeriods.sort();
3014 e341606faeb4 FixA: Use KMIndex for outliers. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3011 diff changeset	268
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	269 FixResult fr = new FixResult(
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	270 results,
3022 705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	271 referenced, outliers,
705d2058b682 FixA: Store the referenced QW for each km, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3020 diff changeset	272 analysisPeriods);
2786 f9e62e76ee1f FixA: Return correct data structure from calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2783 diff changeset	273
f9e62e76ee1f FixA: Return correct data structure from calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2783 diff changeset	274 return new CalculationResult(fr, this);
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	275 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	276
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	277
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	278 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	279
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	280 FixingsColumnFactory fcf = FixingsColumnFactory.getInstance();
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 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	283
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	284 for (int eventId: events) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	285 IdFilter idFilter = new IdFilter(eventId);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	286
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	287 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	288
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	289 if (metas.isEmpty()) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	290 // TODO: i18n
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	291 addProblem("fix.missing.column", eventId);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	292 continue;
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	293 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	294
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	295 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	296 if (data == null) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	297 // TODO: i18n
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	298 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	299 continue;
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	300 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	301
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	302 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	303 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	304
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	305 return columns;
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
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	308 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	309 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	310 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	311 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	312 ) {
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 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	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 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	316 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	317
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	318 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	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 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	321
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	322 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	323 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	324
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 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	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 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	328
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	329 KMIndex<AnalysisPeriod []> results =
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	330 new KMIndex<AnalysisPeriod []>(parameters.size());
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	331
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	332 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	333 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	334 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	335
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 // 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	337 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	338 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	339
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 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	341
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	342 ArrayList<AnalysisPeriod> periodResults =
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	343 new ArrayList<AnalysisPeriod>(analysisPeriods.length);
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	344
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	345 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	346 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	347 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	348 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	349
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	350 QWD [] qSectorAverages = new QWD[4];
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	351 ArrayList<QWD> allQWDs = new ArrayList<QWD>();
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	352
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	353 // 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	354 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	355
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 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	357 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	358 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	359 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	360
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 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	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 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	364 // 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	365 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	366 }
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
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 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	369 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	370
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 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	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 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	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 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	376 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	377 // 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	378 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	379 }
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
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 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	382 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	383 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	384 }
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
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 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	387 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	388 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	389 }
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
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 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	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 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	394 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	395
3106 23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	396 QWD qwd = new QWD(
23de6d678fba FixA: Store into QWs if they are interpolated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3096 diff changeset	397 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	398
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	399 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	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 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	402 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	403
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 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	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
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 // 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	408 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	409 if (N > 0) {
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	410 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	411 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	412 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	413
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 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	415 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	416 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	417 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	418
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 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	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 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	422 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	423
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	424 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	425 }
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	426 }
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 } // for all Q sectors
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	428
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	429 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	430
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	431 AnalysisPeriod periodResult = new AnalysisPeriod(
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	432 analysisPeriod, aqwds, qSectorAverages);
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	433 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	434 }
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	435
3065 ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	436 double maxQ = -Double.MAX_VALUE;
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	437 for (AnalysisPeriod ap: periodResults) {
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	438 double q = ap.getMaxQ();
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	439 if (q > maxQ) {
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	440 maxQ = q;
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	441 }
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	442 }
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 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	445 if (oldMaxQ < maxQ) {
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	446 parameters.set(row, maxQIndex, maxQ);
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	447 }
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	448
3020 ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	449 results.add(km, periodResults.toArray(
ce796f1db30e FixA: Store AnalysisPeriods into FixResult now. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3014 diff changeset	450 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	451 }
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	452
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 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	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
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	456 /** 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	457 * and the real data.
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	458 */
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	459 protected static class Column {
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 Fixing.Column meta;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	462 protected FixingsColumn data;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	463
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	464 public Column() {
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
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	467 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	468 this.meta = meta;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	469 this.data = data;
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	470 }
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	471
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	472 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	473 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	474 }
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
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 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	477 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	478 }
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
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	480 public boolean getQW(
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	481 double km,
5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3065 diff changeset	482 double [] qs,
3011 ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	483 double [] ws,
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	484 int index
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	485 ) {
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	486 qs[index] = data.getQ(km);
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	487 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	488 }
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	489
ab81ffd1343e FixA: Reactivated rewrite of the outlier checks. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3010 diff changeset	490 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	491 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	492 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	493 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	494 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	495 }
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	496 } // class Column
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	497
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	498
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	499 /**
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 * 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	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 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	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 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	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 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	507 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	508 }
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
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 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	511 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	512 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	513 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	514 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	515 .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	516 .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	517 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	518 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	519 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	520 }
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 }
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 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	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 } // 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	525
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	526 /** 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	527 protected Column [][] getAnalysisColumns(FixingsOverview overview) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	528
2993 70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	529 boolean debug = log.isDebugEnabled();
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	530 if (debug) {
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	531 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	532 }
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	533
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	534 Column columns [][] = new Column[analysisPeriods.length][];
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	535
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	536 Range range = new Range(from, to);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	537 SectorRangeFilter sectorRangeFilter =
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	538 new SectorRangeFilter(qSectorStart, qSectorEnd);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	539
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	540 FixingsColumnFactory fcf = FixingsColumnFactory.getInstance();
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 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	543
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	544 // Construct filter for period.
3003 e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	545 DateRange period = analysisPeriods[i];
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	546
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	547 AndFilter filter = new AndFilter();
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 DateRangeFilter dateRangeFilter =
3003 e5e6363e6cba FixA: Explicit model for date ranges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2994 diff changeset	550 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	551
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	552 filter.add(dateRangeFilter);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	553 filter.add(sectorRangeFilter);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	554
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	555 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	556
2993 70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	557 if (debug) {
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	558 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	559 }
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	560
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	561 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	562
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	563 // Only use columns which have data.
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	564 for (Fixing.Column meta: metaCols) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	565 FixingsColumn data = fcf.getColumnData(meta);
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	566 if (data != null) {
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	567 cols.add(new Column(meta, data));
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	568 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	569 }
2993 70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	570
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	571 if (debug) {
70469e3d34b9 FixA: Made Delta W/t calculation finally work Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2992 diff changeset	572 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	573 }
2744 c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	574 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	575 }
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	576
c1f2e792704a FixA: Calculate Delta W/t, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2729 diff changeset	577 return columns;
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	578 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	579
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	580 protected static String [] createColumnNames(String [] parameters) {
3065 ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	581 String [] result = new String[parameters.length + 3];
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	582 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	583 result[1] = "chi_sqr";
3065 ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	584 result[2] = "max_q";
ee653971fa84 FixA: Figure out max Q during fitting. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3029 diff changeset	585 System.arraycopy(parameters, 0, result, 3, parameters.length);
2729 a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	586 return result;
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	587 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	588 }
a441be7f1589 Added Fix calculation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	589 // 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 @ 3106:23de6d678fba