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

added ITransformation

parent 23cfca35
No related branches found
No related tags found
No related merge requests found
......@@ -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;
}
......
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();
}
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