From 84acd004b7e309c7155aa484c4723c5800ef26c8 Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Mon, 8 Feb 2016 15:00:31 +0100
Subject: [PATCH] adopted api changes
---
.../filesystem/format/text/file/TextLine2RecordFilter.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/main/java/teetime/stage/io/filesystem/format/text/file/TextLine2RecordFilter.java b/src/main/java/teetime/stage/io/filesystem/format/text/file/TextLine2RecordFilter.java
index 34c31de9..44418b99 100644
--- a/src/main/java/teetime/stage/io/filesystem/format/text/file/TextLine2RecordFilter.java
+++ b/src/main/java/teetime/stage/io/filesystem/format/text/file/TextLine2RecordFilter.java
@@ -22,7 +22,7 @@ import teetime.framework.AbstractConsumerStage;
import teetime.framework.OutputPort;
import teetime.stage.className.ClassNameRegistryRepository;
import teetime.stage.util.MappingException;
-import teetime.stage.util.TextLine;
+import teetime.stage.util.TextLineContainer;
import kieker.common.exception.IllegalRecordFormatException;
import kieker.common.exception.MonitoringRecordException;
@@ -34,7 +34,7 @@ import kieker.common.record.IMonitoringRecord;
*
* @since 1.10
*/
-public class TextLine2RecordFilter extends AbstractConsumerStage<TextLine> {
+public class TextLine2RecordFilter extends AbstractConsumerStage<TextLineContainer> {
private final OutputPort<IMonitoringRecord> outputPort = this.createOutputPort();
@@ -77,7 +77,7 @@ public class TextLine2RecordFilter extends AbstractConsumerStage<TextLine> {
}
@Override
- protected void execute(final TextLine textLine) {
+ protected void execute(final TextLineContainer textLine) {
try {
final IMonitoringRecord record = this.recordFromTextLineCreator.createRecordFromLine(textLine.getTextFile(), textLine.getTextLine());
outputPort.send(record);
--
GitLab