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

added basic generic stages to extend from (will replace

AbstractProducer/ConsumerStage)
parent b5b24312
No related branches found
No related tags found
No related merge requests found
package teetime.stage.basic;
public abstract class AbstractFilter<E> extends AbstractTransform<E, E> {
protected AbstractFilter() {
super();
}
}
package teetime.stage.basic;
import teetime.framework.AbstractConsumerStage;
import teetime.framework.OutputPort;
public abstract class AbstractTransform<I, O> extends AbstractConsumerStage<I> {
private final OutputPort<O> outputPort = createOutputPort();
protected AbstractTransform() {
super();
}
public OutputPort<O> getOutputPort() {
return outputPort;
}
}
package teetime.stage.basic;
import teetime.framework.AbstractStage;
import teetime.framework.InputPort;
import teetime.framework.OutputPort;
abstract class AbstractTrigger<I, T, O> extends AbstractStage {
private final InputPort<I> inputPort = createInputPort();
private final InputPort<T> triggerInputPort = createInputPort();
private final OutputPort<O> outputPort = createOutputPort();
protected AbstractTrigger() {
super();
}
@Override
protected void executeWithPorts() {
// TODO Auto-generated method stub
}
@Override
public void onTerminating() throws Exception {
// TODO Auto-generated method stub
super.onTerminating();
}
}
wiki @ 0e447457
Subproject commit 63ccbbc87bd2c0e6599ca91502149dba3cfb99de
Subproject commit 0e4474577e1f49bc96e734c286b2d9e0363895e8
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