Implemented the retriever for tracked legs

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);
     }

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;
     }
 
 }

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);
     }