From 0999de028751b40435d995cfaa69aa90fb01a095 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Wed, 24 Jun 2015 10:23:48 +0200
Subject: [PATCH] added ITransformation
---
.../teetime/stage/basic/AbstractTransformation.java | 3 ++-
.../java/teetime/stage/basic/ITransformation.java | 12 ++++++++++++
2 files changed, 14 insertions(+), 1 deletion(-)
create mode 100644 src/main/java/teetime/stage/basic/ITransformation.java
diff --git a/src/main/java/teetime/stage/basic/AbstractTransformation.java b/src/main/java/teetime/stage/basic/AbstractTransformation.java
index 39cc3481..35fc4e81 100644
--- a/src/main/java/teetime/stage/basic/AbstractTransformation.java
+++ b/src/main/java/teetime/stage/basic/AbstractTransformation.java
@@ -18,7 +18,7 @@ package teetime.stage.basic;
import teetime.framework.AbstractConsumerStage;
import teetime.framework.OutputPort;
-public abstract class AbstractTransformation<I, O> extends AbstractConsumerStage<I> {
+public abstract class AbstractTransformation<I, O> extends AbstractConsumerStage<I> implements ITransformation<I, O> {
private final OutputPort<O> outputPort = createOutputPort();
@@ -26,6 +26,7 @@ public abstract class AbstractTransformation<I, O> extends AbstractConsumerStage
super();
}
+ @Override
public OutputPort<O> getOutputPort() {
return outputPort;
}
diff --git a/src/main/java/teetime/stage/basic/ITransformation.java b/src/main/java/teetime/stage/basic/ITransformation.java
new file mode 100644
index 00000000..7efae2a0
--- /dev/null
+++ b/src/main/java/teetime/stage/basic/ITransformation.java
@@ -0,0 +1,12 @@
+package teetime.stage.basic;
+
+import teetime.framework.InputPort;
+import teetime.framework.OutputPort;
+
+public interface ITransformation<I, O> {
+
+ public abstract InputPort<I> getInputPort();
+
+ public abstract OutputPort<O> getOutputPort();
+
+}
--
GitLab