Skip to content
Snippets Groups Projects

added CountCSVWriterStage

Merged Sören Henning requested to merge thesis-eval into master
1 file
+ 43
0
Compare changes
  • Side-by-side
  • Inline
package kiekpad.analysis.util;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.PrintWriter;
import java.time.Duration;
import java.time.Instant;
import teetime.framework.AbstractConsumerStage;
public class CountCSVWriterStage extends AbstractConsumerStage<Object> {
private final PrintWriter printWriter;
private int counter = 0;
private final Instant start;
public CountCSVWriterStage(final File file) {
try {
this.printWriter = new PrintWriter(file);
} catch (FileNotFoundException e) {
throw new IllegalStateException(e);
}
this.start = Instant.now();
writeRow();
}
@Override
protected void execute(final Object object) {
this.counter++;
writeRow();
}
@Override
public void onTerminating() {
this.printWriter.close();
}
private void writeRow() {
final long time = Duration.between(this.start, Instant.now()).toNanos();
this.printWriter.write(time + "," + this.counter);
}
}
Loading