Skip to content
Snippets Groups Projects
Commit 8bff2e32 authored by Christian Wulf's avatar Christian Wulf
Browse files

fixed compiler errors

parent 2ef8864b
No related branches found
No related tags found
No related merge requests found
...@@ -19,6 +19,7 @@ import java.io.FileWriter; ...@@ -19,6 +19,7 @@ import java.io.FileWriter;
import java.io.IOException; import java.io.IOException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.Collection;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
...@@ -133,6 +134,9 @@ public class Experiment2 { ...@@ -133,6 +134,9 @@ public class Experiment2 {
private WorkerThread workerThread; private WorkerThread workerThread;
private final boolean shouldUseQueue; private final boolean shouldUseQueue;
// FIXME instantiate me
private Collection<TimestampObject> timestampObjects;
public TeeTimeAnalysis(final boolean shouldUseQueue) { public TeeTimeAnalysis(final boolean shouldUseQueue) {
this.shouldUseQueue = shouldUseQueue; this.shouldUseQueue = shouldUseQueue;
} }
...@@ -216,6 +220,9 @@ public class Experiment2 { ...@@ -216,6 +220,9 @@ public class Experiment2 {
private IAnalysisController ac; private IAnalysisController ac;
// FIXME instantiate me
private Collection<TimestampObject> timestampObjects;
public KiekerAnalysis() {} public KiekerAnalysis() {}
@Override @Override
......
...@@ -46,7 +46,7 @@ import teetime.stage.util.TextLine; ...@@ -46,7 +46,7 @@ import teetime.stage.util.TextLine;
/** /**
* @author Christian Wulf * @author Christian Wulf
* *
* @since 1.10 * @since 1.10
*/ */
public class TraceReconstructionAnalysis2 extends Analysis { public class TraceReconstructionAnalysis2 extends Analysis {
...@@ -111,11 +111,11 @@ public class TraceReconstructionAnalysis2 extends Analysis { ...@@ -111,11 +111,11 @@ public class TraceReconstructionAnalysis2 extends Analysis {
QueuePipe.connect(cache.objectOutputPort, textLine2RecordFilter.textLineInputPort); QueuePipe.connect(cache.objectOutputPort, textLine2RecordFilter.textLineInputPort);
QueuePipe.connect(textLine2RecordFilter.recordOutputPort, stringBufferFilter.objectInputPort); QueuePipe.connect(textLine2RecordFilter.recordOutputPort, stringBufferFilter.objectInputPort);
QueuePipe.connect(stringBufferFilter.objectOutputPort, timestampFilter.inputPort); QueuePipe.connect(stringBufferFilter.objectOutputPort, timestampFilter.inputPort);
QueuePipe.connect(timestampFilter.matchingOutputPort, traceIdFilter.inputPort); // QueuePipe.connect(timestampFilter.matchingOutputPort, traceIdFilter.inputPort);
// QueuePipe.connect(timestampFilter.mismatchingOutputPort, YYY); // ignore this case // QueuePipe.connect(timestampFilter.mismatchingOutputPort, YYY); // ignore this case
QueuePipe.connect(traceIdFilter.matchingOutputPort, instanceOfFilter.inputPort); QueuePipe.connect(traceIdFilter.matchingOutputPort, instanceOfFilter.inputPort);
// QueuePipe.connect(traceIdFilter.mismatchingOutputPort, traceIdFilter.inputPort); // ignore this case // QueuePipe.connect(traceIdFilter.mismatchingOutputPort, traceIdFilter.inputPort); // ignore this case
QueuePipe.connect(XXX, traceReconstructionFilter.timestampInputPort); // QueuePipe.connect(XXX, traceReconstructionFilter.timestampInputPort);
QueuePipe.connect(instanceOfFilter.matchingOutputPort, traceReconstructionFilter.recordInputPort); QueuePipe.connect(instanceOfFilter.matchingOutputPort, traceReconstructionFilter.recordInputPort);
// QueuePipe.connect(instanceOfFilter.mismatchingOutputPort, instanceOfFilter.inputPort); // ignore this case // QueuePipe.connect(instanceOfFilter.mismatchingOutputPort, instanceOfFilter.inputPort); // ignore this case
QueuePipe.connect(traceReconstructionFilter.traceValidOutputPort, countingFilter.INPUT_OBJECT); QueuePipe.connect(traceReconstructionFilter.traceValidOutputPort, countingFilter.INPUT_OBJECT);
......
...@@ -16,7 +16,6 @@ ...@@ -16,7 +16,6 @@
package teetime.stage; package teetime.stage;
import java.util.Collection; import java.util.Collection;
import java.util.concurrent.TimeUnit;
import teetime.framework.core.AbstractFilter; import teetime.framework.core.AbstractFilter;
import teetime.framework.core.Context; import teetime.framework.core.Context;
...@@ -53,9 +52,9 @@ public class CollectorSink<T> extends AbstractFilter<CollectorSink<T>> { ...@@ -53,9 +52,9 @@ public class CollectorSink<T> extends AbstractFilter<CollectorSink<T>> {
this.objects.add(object); this.objects.add(object);
if ((this.objects.size() % THRESHOLD) == 0) { if ((this.objects.size() % THRESHOLD) == 0) {
System.out.println("size: " + this.objects.size()); System.out.println("size: " + this.objects.size());
stopWatch.end(); // stopWatch.end();
System.out.println("duration: "+TimeUnit.NANOSECONDS.toMillis(stopWatch.getDurationInNs())+" ms"); // System.out.println("duration: "+TimeUnit.NANOSECONDS.toMillis(stopWatch.getDurationInNs())+" ms");
stopWatch.start(); // stopWatch.start();
} }
return true; return true;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment