Added test for the processor finishing

This commit is contained in:
Lennart Hensler committed 2014-02-22 14:15:02 +01:00
1 parent 5c494b521e
commit eb63251e94
15 files changed
+256 -153

No files matched your search

@@ -9,25 +9,22 @@ import com.sap.sailing.server.RacingEventService;
import com.sap.sse.datamining.components.Processor;
import com.sap.sse.datamining.impl.components.AbstractPartitioningParallelProcessor;
public class GPSFixRetrievalProcessor extends AbstractPartitioningParallelProcessor<RacingEventService,
LeaderboardGroup,
GPSFixWithContext> {
public class GPSFixRetrievalProcessor extends
AbstractPartitioningParallelProcessor<RacingEventService, LeaderboardGroup, GPSFixWithContext> {
public GPSFixRetrievalProcessor(Executor executor,
Collection<Processor<GPSFixWithContext>> resultReceivers) {
super(executor, resultReceivers);
}
public GPSFixRetrievalProcessor(Executor executor, Collection<Processor<GPSFixWithContext>> resultReceivers) {
super(executor, resultReceivers);
}
@Override
protected Runnable createInstruction(LeaderboardGroup partialElement) {
// TODO Auto-generated method stub
return null;
}
@Override
protected Runnable createInstruction(LeaderboardGroup partialElement) {
// TODO Auto-generated method stub
return null;
}
@Override
protected Iterable<LeaderboardGroup> partitionElement(
RacingEventService element) {
return null;
}
@Override
protected Iterable<LeaderboardGroup> partitionElement(RacingEventService element) {
return null;
}
}