From 1bc19d7fc87433aeb804952873575276969ff610 Mon Sep 17 00:00:00 2001
From: Lennart Hensler <lennarthensler@aol.com>
Date: Thu, 1 May 2014 19:49:37 +0200
Subject: [PATCH] Implemented the retriever for tracked legs

---
 ...aderboardFilteringRetrievalProcessor.java} |  4 ++--
 ...rackedLegFilteringRetrievalProcessor.java} | 21 +++++++++++--------
 ...ackedRaceFilteringRetrievalProcessor.java} |  4 ++--
 3 files changed, 16 insertions(+), 13 deletions(-)
 rename java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/{RegattaLeaderboardRetrievalProcessor.java => RegattaLeaderboardFilteringRetrievalProcessor.java} (89%)
 rename java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/{TrackedLegRetrievalProcessor.java => TrackedLegFilteringRetrievalProcessor.java} (51%)
 rename java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/{TrackedRaceRetrievalProcessor.java => TrackedRaceFilteringRetrievalProcessor.java} (93%)

diff --git a/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/RegattaLeaderboardRetrievalProcessor.java b/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/RegattaLeaderboardFilteringRetrievalProcessor.java
similarity index 89%
rename from java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/RegattaLeaderboardRetrievalProcessor.java
rename to java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/RegattaLeaderboardFilteringRetrievalProcessor.java
index 8bba1b7514f..aec6c5ccd24 100644
--- a/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/RegattaLeaderboardRetrievalProcessor.java
+++ b/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/RegattaLeaderboardFilteringRetrievalProcessor.java
@@ -11,10 +11,10 @@ import com.sap.sse.datamining.components.FilterCriteria;
 import com.sap.sse.datamining.components.Processor;
 import com.sap.sse.datamining.impl.components.AbstractSimpleFilteringRetrievalProcessor;
 
-public class RegattaLeaderboardRetrievalProcessor extends
+public class RegattaLeaderboardFilteringRetrievalProcessor extends
         AbstractSimpleFilteringRetrievalProcessor<LeaderboardGroup, RegattaLeaderboard> {
 
-    public RegattaLeaderboardRetrievalProcessor(ExecutorService executor,
+    public RegattaLeaderboardFilteringRetrievalProcessor(ExecutorService executor,
             Collection<Processor<RegattaLeaderboard>> resultReceivers, FilterCriteria<RegattaLeaderboard> criteria) {
         super(executor, resultReceivers, criteria);
     }
diff --git a/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedLegRetrievalProcessor.java b/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedLegFilteringRetrievalProcessor.java
similarity index 51%
rename from java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedLegRetrievalProcessor.java
rename to java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedLegFilteringRetrievalProcessor.java
index 7681b7e73bd..292101a4817 100644
--- a/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedLegRetrievalProcessor.java
+++ b/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedLegFilteringRetrievalProcessor.java
@@ -1,32 +1,35 @@
 package com.sap.sailing.datamining.impl.components;
 
+import java.util.ArrayList;
 import java.util.Collection;
 import java.util.concurrent.ExecutorService;
 
 import com.sap.sailing.datamining.data.HasTrackedLegContext;
+import com.sap.sailing.datamining.data.HasTrackedRaceContext;
 import com.sap.sailing.datamining.impl.data.HasTrackedLegContextImpl;
 import com.sap.sailing.domain.tracking.TrackedLeg;
-import com.sap.sailing.domain.tracking.TrackedRace;
 import com.sap.sse.datamining.components.FilterCriteria;
 import com.sap.sse.datamining.components.Processor;
 import com.sap.sse.datamining.impl.components.AbstractSimpleFilteringRetrievalProcessor;
 
-public class TrackedLegRetrievalProcessor extends
-        AbstractSimpleFilteringRetrievalProcessor<TrackedRace, HasTrackedLegContext> {
+public class TrackedLegFilteringRetrievalProcessor extends
+        AbstractSimpleFilteringRetrievalProcessor<HasTrackedRaceContext, HasTrackedLegContext> {
 
-    public TrackedLegRetrievalProcessor(ExecutorService executor,
+    public TrackedLegFilteringRetrievalProcessor(ExecutorService executor,
             Collection<Processor<HasTrackedLegContext>> resultReceivers, FilterCriteria<HasTrackedLegContext> criteria) {
         super(executor, resultReceivers, criteria);
     }
 
     @Override
-    protected Iterable<HasTrackedLegContext> retrieveData(TrackedRace element) {
+    protected Iterable<HasTrackedLegContext> retrieveData(HasTrackedRaceContext element) {
+        Collection<HasTrackedLegContext> trackedLegsWithContext = new ArrayList<>();
         int legNumber = 1;
-        for (TrackedLeg trackedLeg : element.getTrackedLegs()) {
-            //TODO find a way to push the previous context through the process chain
-            HasTrackedLegContext trackedLegWithContext = new HasTrackedLegContextImpl(trackedRaceContext, trackedLeg, legNumber);
+        for (TrackedLeg trackedLeg : element.getTrackedRace().getTrackedLegs()) {
+            HasTrackedLegContext trackedLegWithContext = new HasTrackedLegContextImpl(element, trackedLeg, legNumber);
+            trackedLegsWithContext.add(trackedLegWithContext);
+            legNumber++;
         }
-        return null;
+        return trackedLegsWithContext;
     }
 
 }
diff --git a/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedRaceRetrievalProcessor.java b/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedRaceFilteringRetrievalProcessor.java
similarity index 93%
rename from java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedRaceRetrievalProcessor.java
rename to java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedRaceFilteringRetrievalProcessor.java
index 255463bf8dd..04de3378a68 100644
--- a/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedRaceRetrievalProcessor.java
+++ b/java/com.sap.sailing.datamining/src/com/sap/sailing/datamining/impl/components/TrackedRaceFilteringRetrievalProcessor.java
@@ -16,10 +16,10 @@ import com.sap.sse.datamining.components.FilterCriteria;
 import com.sap.sse.datamining.components.Processor;
 import com.sap.sse.datamining.impl.components.AbstractSimpleFilteringRetrievalProcessor;
 
-public class TrackedRaceRetrievalProcessor extends
+public class TrackedRaceFilteringRetrievalProcessor extends
         AbstractSimpleFilteringRetrievalProcessor<Leaderboard, HasTrackedRaceContext> {
 
-    public TrackedRaceRetrievalProcessor(ExecutorService executor,
+    public TrackedRaceFilteringRetrievalProcessor(ExecutorService executor,
             Collection<Processor<HasTrackedRaceContext>> resultReceivers, FilterCriteria<HasTrackedRaceContext> criteria) {
         super(executor, resultReceivers, criteria);
     }